@@ -133,7 +133,6 @@ discard block |
||
| 133 | 133 | /** |
| 134 | 134 | * Set the source (Binding). |
| 135 | 135 | * |
| 136 | - * @param Binding $source |
|
| 137 | 136 | * @param string $name |
| 138 | 137 | * @param ConsumerInterface[] $consumers |
| 139 | 138 | */ |
@@ -454,7 +453,6 @@ discard block |
||
| 454 | 453 | /** |
| 455 | 454 | * Set RabbitMq specific parameter : max length. |
| 456 | 455 | * |
| 457 | - * @param int $ttl |
|
| 458 | 456 | * |
| 459 | 457 | * @return Queue |
| 460 | 458 | */ |
@@ -539,7 +539,7 @@ |
||
| 539 | 539 | $consumer->isNoAck(), |
| 540 | 540 | $consumer->isExclusive(), |
| 541 | 541 | $consumer->isNoWait(), |
| 542 | - function (AMQPMessage $msg) use ($consumer) { |
|
| 542 | + function(AMQPMessage $msg) use ($consumer) { |
|
| 543 | 543 | $consumer->callback($msg); |
| 544 | 544 | }, |
| 545 | 545 | $consumer->getTicket(), |