@@ -202,7 +202,7 @@ |
||
202 | 202 | $flags = $autoAck ? AMQP_AUTOACK : AMQP_NOPARAM; |
203 | 203 | $consumerTag = self::generateConsumerTag(); |
204 | 204 | try { |
205 | - $queue->consume(function (\AMQPEnvelope $message) use ($callback, $queueName) { |
|
205 | + $queue->consume(function(\AMQPEnvelope $message) use ($callback, $queueName) { |
|
206 | 206 | |
207 | 207 | $burrowMessage = new Message( |
208 | 208 | $message->getBody(), |