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