@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | |
83 | 83 | $this->log( |
84 | 84 | LogLevel::INFO, |
85 | - "Dispatcher send message #{$message->getId()} with priority {$priority} to driver " . get_class($this->driver), |
|
85 | + "Dispatcher send message #{$message->getId()} with priority {$priority} to driver ".get_class($this->driver), |
|
86 | 86 | $this->messageLoggerContext($message) |
87 | 87 | ); |
88 | 88 | return $this; |
@@ -102,7 +102,7 @@ discard block |
||
102 | 102 | public function handle(array $priorities = []): void |
103 | 103 | { |
104 | 104 | try { |
105 | - $this->driver->wait(function (MessageInterface $message, int $priority = Dispatcher::DEFAULT_PRIORITY) { |
|
105 | + $this->driver->wait(function(MessageInterface $message, int $priority = Dispatcher::DEFAULT_PRIORITY) { |
|
106 | 106 | $this->log( |
107 | 107 | LogLevel::INFO, |
108 | 108 | "Start handle message #{$message->getId()} ({$message->getType()}) priority:{$priority}", |
@@ -180,7 +180,7 @@ discard block |
||
180 | 180 | } catch (Exception $e) { |
181 | 181 | $this->log( |
182 | 182 | LogLevel::ERROR, |
183 | - "Handler " . get_class($handler) . " throws exception - {$e->getMessage()}", |
|
183 | + "Handler ".get_class($handler)." throws exception - {$e->getMessage()}", |
|
184 | 184 | ['error' => $e, 'message' => $this->messageLoggerContext($message), 'exception' => $e] |
185 | 185 | ); |
186 | 186 | if (Debugger::isEnabled()) { |
@@ -279,7 +279,7 @@ discard block |
||
279 | 279 | } |
280 | 280 | $this->handlers[$type] = array_filter( |
281 | 281 | $this->handlers[$type], |
282 | - function (HandlerInterface $registeredHandler) use ($handler) { |
|
282 | + function(HandlerInterface $registeredHandler) use ($handler) { |
|
283 | 283 | return $registeredHandler !== $handler; |
284 | 284 | } |
285 | 285 | ); |