@@ -68,7 +68,7 @@ |
||
68 | 68 | */ |
69 | 69 | public function handle() |
70 | 70 | { |
71 | - $this->driver->wait(function (MessageInterface $message) { |
|
71 | + $this->driver->wait(function(MessageInterface $message) { |
|
72 | 72 | $this->log( |
73 | 73 | LogLevel::INFO, |
74 | 74 | "Start handle message #{$message->getId()} ({$message->getType()})", |
@@ -62,7 +62,7 @@ |
||
62 | 62 | true, |
63 | 63 | false, |
64 | 64 | false, |
65 | - function ($rabbitMessage) use ($callback) { |
|
65 | + function($rabbitMessage) use ($callback) { |
|
66 | 66 | $message = $this->serializer->unserialize($rabbitMessage->body); |
67 | 67 | $callback($message); |
68 | 68 | } |