@@ -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 | ]); |