@@ -24,6 +24,10 @@ discard block |
||
24 | 24 | private $correlationId; |
25 | 25 | private $callbackQueue; |
26 | 26 | |
27 | + /** |
|
28 | + * @param string $queueName |
|
29 | + * @param string $fromName |
|
30 | + */ |
|
27 | 31 | public function __construct($queueName, ConnectionManager $manager, $fromName, $connectionName = 'default') |
28 | 32 | { |
29 | 33 | $this->connectionName = $connectionName; |
@@ -71,7 +75,7 @@ discard block |
||
71 | 75 | } |
72 | 76 | |
73 | 77 | /** |
74 | - * @param $data |
|
78 | + * @param string $data |
|
75 | 79 | * @param int $expire |
76 | 80 | * @param int $priority |
77 | 81 | * @throws QueueNotFoundException |
@@ -150,7 +154,7 @@ discard block |
||
150 | 154 | /** |
151 | 155 | * @todo unecessary method set, its only exists to run tests whitout stay jailed in infinite while waiting response. |
152 | 156 | * |
153 | - * @param $content |
|
157 | + * @param string $content |
|
154 | 158 | */ |
155 | 159 | public function setResponse($content) |
156 | 160 | { |
@@ -180,7 +184,7 @@ discard block |
||
180 | 184 | } |
181 | 185 | |
182 | 186 | /** |
183 | - * @return string |
|
187 | + * @return boolean |
|
184 | 188 | */ |
185 | 189 | public function getExchange() |
186 | 190 | { |
@@ -188,7 +192,7 @@ discard block |
||
188 | 192 | } |
189 | 193 | |
190 | 194 | /** |
191 | - * @return string |
|
195 | + * @return boolean |
|
192 | 196 | */ |
193 | 197 | public function getExchangeType() |
194 | 198 | { |
@@ -205,8 +209,8 @@ discard block |
||
205 | 209 | |
206 | 210 | /** |
207 | 211 | * @param CmobiAMQPConnectionInterface $connection |
208 | - * @param $expire |
|
209 | - * @param $sufix |
|
212 | + * @param integer $expire |
|
213 | + * @param string $sufix |
|
210 | 214 | * @param $corralationId |
211 | 215 | * @return CmobiAMQPConnectionInterface |
212 | 216 | */ |