@@ -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; |