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