@@ -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; |
@@ -74,7 +78,7 @@ discard block |
||
74 | 78 | } |
75 | 79 | |
76 | 80 | /** |
77 | - * @param $data |
|
81 | + * @param string $data |
|
78 | 82 | * @param int $expire |
79 | 83 | * @param int $priority |
80 | 84 | * @throws QueueNotFoundException |
@@ -151,7 +155,7 @@ discard block |
||
151 | 155 | /** |
152 | 156 | * @todo unecessary method set, its only exists to run tests whitout stay jailed in infinite while waiting response. |
153 | 157 | * |
154 | - * @param $content |
|
158 | + * @param string $content |
|
155 | 159 | */ |
156 | 160 | public function setResponse($content) |
157 | 161 | { |
@@ -181,7 +185,7 @@ discard block |
||
181 | 185 | } |
182 | 186 | |
183 | 187 | /** |
184 | - * @return string |
|
188 | + * @return boolean |
|
185 | 189 | */ |
186 | 190 | public function getExchange() |
187 | 191 | { |
@@ -189,7 +193,7 @@ discard block |
||
189 | 193 | } |
190 | 194 | |
191 | 195 | /** |
192 | - * @return string |
|
196 | + * @return boolean |
|
193 | 197 | */ |
194 | 198 | public function getExchangeType() |
195 | 199 | { |
@@ -206,7 +210,7 @@ discard block |
||
206 | 210 | |
207 | 211 | /** |
208 | 212 | * @param CmobiAMQPConnectionInterface $connection |
209 | - * @param $expire |
|
213 | + * @param integer $expire |
|
210 | 214 | * @param $corralationId |
211 | 215 | * @return CmobiAMQPConnectionInterface |
212 | 216 | */ |