@@ -140,7 +140,7 @@ discard block |
||
140 | 140 | } |
141 | 141 | |
142 | 142 | /** |
143 | - * @param array $exchangeInformation |
|
143 | + * @param string[] $exchangeInformation |
|
144 | 144 | * |
145 | 145 | * @throws AssertionFailedException |
146 | 146 | */ |
@@ -180,7 +180,7 @@ discard block |
||
180 | 180 | } |
181 | 181 | |
182 | 182 | /** |
183 | - * @param array $exchangeInformation |
|
183 | + * @param string[] $exchangeInformation |
|
184 | 184 | * @param OutputInterface $output |
185 | 185 | */ |
186 | 186 | private function bindExchange(array $exchangeInformation, OutputInterface $output) |
@@ -207,7 +207,7 @@ discard block |
||
207 | 207 | |
208 | 208 | /** |
209 | 209 | * @param string $exchangeName |
210 | - * @param array $queueInformation |
|
210 | + * @param string[] $queueInformation |
|
211 | 211 | * @param OutputInterface $output |
212 | 212 | */ |
213 | 213 | private function bindQueue( |
@@ -253,7 +253,7 @@ discard block |
||
253 | 253 | } |
254 | 254 | |
255 | 255 | /** |
256 | - * @param $timeout |
|
256 | + * @param integer $timeout |
|
257 | 257 | * |
258 | 258 | * @throws Exception |
259 | 259 | */ |
@@ -302,7 +302,7 @@ discard block |
||
302 | 302 | /** |
303 | 303 | * @param AMQPMessage $message |
304 | 304 | * |
305 | - * @return array |
|
305 | + * @return string[] |
|
306 | 306 | * |
307 | 307 | * @throws \OutOfBoundsException |
308 | 308 | */ |
@@ -338,6 +338,9 @@ discard block |
||
338 | 338 | $message->get(self::REPLY_TO) : ''; |
339 | 339 | } |
340 | 340 | |
341 | + /** |
|
342 | + * @param string $exchangeName |
|
343 | + */ |
|
341 | 344 | private function retryPublish($exchangeName, Message $message) |
342 | 345 | { |
343 | 346 | $this->retryPublish = true; |