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