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