@@ -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(), |