tomaj / hermes

src/Driver/RedisSetDriver.php

Unused Use Statements +2 added lines, -3 removed lines

@@ -2,11 +2,10 @@
 
 namespace Tomaj\Hermes\Driver;
 
-use Exception;
-use Tomaj\Hermes\MessageInterface;
 use Closure;
-use Tomaj\Hermes\MessageSerializer;
 use InvalidArgumentException;
+use Tomaj\Hermes\MessageInterface;
+use Tomaj\Hermes\MessageSerializer;
 
 class RedisSetDriver implements DriverInterface
 {

src/Driver/ZeroMqDriver.php

Unused Use Statements +1 added lines, -1 removed lines

@@ -2,9 +2,9 @@
 
 namespace Tomaj\Hermes\Driver;
 
+use Closure;
 use Tomaj\Hermes\MessageInterface;
 use Tomaj\Hermes\MessageSerializer;
-use Closure;
 use ZMQSocket;
 
 class ZeroMqDriver implements DriverInterface

src/Emitter.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
 
         $this->log(
             LogLevel::INFO,
-            "Dispatcher send message #{$message->getId()} to driver " . get_class($this->driver),
+            "Dispatcher send message #{$message->getId()} to driver ".get_class($this->driver),
             $this->messageLoggerContext($message)
         );
         return $this;

src/Dispatcher.php

Unused Use Statements +3 added lines, -3 removed lines

@@ -2,15 +2,15 @@
 
 namespace Tomaj\Hermes;
 
+use DateTime;
 use Exception;
-use Psr\Log\LoggerInterface;
 use Psr\Log\LogLevel;
-use Tomaj\Hermes\Handler\HandlerInterface;
+use Psr\Log\LoggerInterface;
 use Tomaj\Hermes\Driver\DriverInterface;
+use Tomaj\Hermes\Handler\HandlerInterface;
 use Tomaj\Hermes\Restart\RestartException;
 use Tomaj\Hermes\Restart\RestartInterface;
 use Tracy\Debugger;
-use DateTime;
 
 class Dispatcher implements DispatcherInterface
 {

Spacing +3 added lines, -3 removed lines

@@ -72,7 +72,7 @@ 
 
         $this->log(
             LogLevel::INFO,
-            "Dispatcher send message #{$message->getId()} to driver " . get_class($this->driver),
+            "Dispatcher send message #{$message->getId()} to driver ".get_class($this->driver),
             $this->messageLoggerContext($message)
         );
         return $this;
@@ -90,7 +90,7 @@ 
     public function handle(): void
     {
         try {
-            $this->driver->wait(function (MessageInterface $message) {
+            $this->driver->wait(function(MessageInterface $message) {
                 $this->log(
                     LogLevel::INFO,
                     "Start handle message #{$message->getId()} ({$message->getType()})",
@@ -168,7 +168,7 @@ 
         } catch (Exception $e) {
             $this->log(
                 LogLevel::ERROR,
-                "Handler " . get_class($handler) . " throws exception - {$e->getMessage()}",
+                "Handler ".get_class($handler)." throws exception - {$e->getMessage()}",
                 ['error' => $e, 'message' => $this->messageLoggerContext($message), 'exception' => $e]
             );
             if (Debugger::isEnabled()) {

examples/redis/processor.php

Unused Use Statements +1 added lines, -1 removed lines

@@ -1,8 +1,8 @@
 <?php
 declare(strict_types=1);
 
-use Tomaj\Hermes\Driver\RedisSetDriver;
 use Tomaj\Hermes\Dispatcher;
+use Tomaj\Hermes\Driver\RedisSetDriver;
 use Tomaj\Hermes\Handler\EchoHandler;
 
 require_once __DIR__.'/../../vendor/autoload.php';

src/Driver/RabbitMqDriver.php

Spacing +1 added lines, -1 removed lines

@@ -64,7 +64,7 @@
             false,
             false,
             false,
-            function ($rabbitMessage) use ($callback) {
+            function($rabbitMessage) use ($callback) {
                 $message = $this->serializer->unserialize($rabbitMessage->body);
                 $callback($message);
                 $rabbitMessage->delivery_info['channel']->basic_ack($rabbitMessage->delivery_info['delivery_tag']);

src/Driver/LazyRabbitMqDriver.php

Spacing +1 added lines, -1 removed lines

@@ -64,7 +64,7 @@
             false,
             false,
             false,
-            function ($rabbitMessage) use ($callback) {
+            function($rabbitMessage) use ($callback) {
                 $message = $this->serializer->unserialize($rabbitMessage->body);
                 $callback($message);
                 $rabbitMessage->delivery_info['channel']->basic_ack($rabbitMessage->delivery_info['delivery_tag']);