@@ -85,7 +85,7 @@ |
||
| 85 | 85 | |
| 86 | 86 | $this->driver->consume( |
| 87 | 87 | $this->queueName, |
| 88 | - function (Message $message) use ($startTime) { |
|
| 88 | + function(Message $message) use ($startTime) { |
|
| 89 | 89 | $this->eventEmitter->emit(new MessageReceived()); |
| 90 | 90 | $this->monitor->monitor($this, $message); |
| 91 | 91 | |