@@ -161,7 +161,7 @@ |
||
161 | 161 | { |
162 | 162 | $client = $this->makeClient(); |
163 | 163 | $queue = new Queue($client, 'test_direct_queue', [ |
164 | - new Consumer(function (AMQPMessage $msg) { |
|
164 | + new Consumer(function(AMQPMessage $msg) { |
|
165 | 165 | $this->msgReceived = $msg; |
166 | 166 | }, new NullLogger()) |
167 | 167 | ]); |