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