@@ -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(), |
@@ -196,7 +196,7 @@ |
||
| 196 | 196 | */ |
| 197 | 197 | public function getQueues() |
| 198 | 198 | { |
| 199 | - return array_filter($this->rabbitMqObjects, function (RabbitMqObjectInterface $object) { |
|
| 199 | + return array_filter($this->rabbitMqObjects, function(RabbitMqObjectInterface $object) { |
|
| 200 | 200 | return $object instanceof QueueInterface; |
| 201 | 201 | }); |
| 202 | 202 | } |