@@ -19,6 +19,9 @@ discard block |
||
19 | 19 | private $correlationId; |
20 | 20 | private $callbackQueue; |
21 | 21 | |
22 | + /** |
|
23 | + * @param string $queueName |
|
24 | + */ |
|
22 | 25 | public function __construct($queueName, ConnectionManager $manager, $fromName = '') |
23 | 26 | { |
24 | 27 | $this->queueName = $queueName; |
@@ -54,7 +57,7 @@ discard block |
||
54 | 57 | } |
55 | 58 | |
56 | 59 | /** |
57 | - * @param $data |
|
60 | + * @param string $data |
|
58 | 61 | * @param int $expire |
59 | 62 | * @param int $priority |
60 | 63 | * @throws QueueNotFoundException |
@@ -140,7 +143,7 @@ discard block |
||
140 | 143 | /** |
141 | 144 | * @todo unecessary method set, its only exists to run tests whitout stay jailed in infinite while waiting response. |
142 | 145 | * |
143 | - * @param $content |
|
146 | + * @param string $content |
|
144 | 147 | */ |
145 | 148 | public function setResponse($content) |
146 | 149 | { |
@@ -170,7 +173,7 @@ discard block |
||
170 | 173 | } |
171 | 174 | |
172 | 175 | /** |
173 | - * @return string |
|
176 | + * @return boolean |
|
174 | 177 | */ |
175 | 178 | public function getExchange() |
176 | 179 | { |
@@ -178,7 +181,7 @@ discard block |
||
178 | 181 | } |
179 | 182 | |
180 | 183 | /** |
181 | - * @return string |
|
184 | + * @return boolean |
|
182 | 185 | */ |
183 | 186 | public function getExchangeType() |
184 | 187 | { |