tomaj / hermes

src/Dispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -85,7 +85,7 @@ 
 
         $this->log(
             LogLevel::INFO,
-            "Dispatcher send message #{$message->getId()} with priority {$priority} to driver " . get_class($this->driver),
+            "Dispatcher send message #{$message->getId()} with priority {$priority} to driver ".get_class($this->driver),
             $this->messageLoggerContext($message)
         );
         return $this;
@@ -105,7 +105,7 @@ 
     public function handle(array $priorities = []): void
     {
         try {
-            $this->driver->wait(function (MessageInterface $message, int $priority = Dispatcher::PRIORITY_MEDIUM) {
+            $this->driver->wait(function(MessageInterface $message, int $priority = Dispatcher::PRIORITY_MEDIUM) {
                 $this->log(
                     LogLevel::INFO,
                     "Start handle message #{$message->getId()} ({$message->getType()}) priority:{$priority}",
@@ -183,7 +183,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()) {

src/Driver/RedisSetDriver.php

Spacing +1 added lines, -1 removed lines

@@ -119,7 +119,7 @@
                 }
             }
             if ($this->redis instanceof Redis) {
-                $messagesString = $this->redis->zRangeByScore($this->scheduleKey, '-inf', (string)microtime(true), ['limit' => [0, 1]]);
+                $messagesString = $this->redis->zRangeByScore($this->scheduleKey, '-inf', (string) microtime(true), ['limit' => [0, 1]]);
                 if (count($messagesString)) {
                     foreach ($messagesString as $messageString) {
                         $this->redis->zRem($this->scheduleKey, $messageString);

examples/redis/processor.php

Spacing +2 added lines, -2 removed lines

@@ -12,8 +12,8 @@
 $redis->connect('127.0.0.1', 6379);
 $driver = new RedisSetDriver($redis, 'hermes', 1);
 $driver->setRestart(new RedisRestart($redis));
-$driver->setupPriorityQueue('hermes_low',\Tomaj\Hermes\Dispatcher::PRIORITY_LOW);
-$driver->setupPriorityQueue('hermes_high',\Tomaj\Hermes\Dispatcher::PRIORITY_HIGH);
+$driver->setupPriorityQueue('hermes_low', \Tomaj\Hermes\Dispatcher::PRIORITY_LOW);
+$driver->setupPriorityQueue('hermes_high', \Tomaj\Hermes\Dispatcher::PRIORITY_HIGH);
 
 $dispatcher = new Dispatcher($driver);
 

examples/redis/emitter.php

Spacing +2 added lines, -2 removed lines

@@ -10,8 +10,8 @@
 $redis = new Redis();
 $redis->connect('127.0.0.1', 6379);
 $driver = new RedisSetDriver($redis);
-$driver->setupPriorityQueue('hermes_low',\Tomaj\Hermes\Dispatcher::PRIORITY_LOW);
-$driver->setupPriorityQueue('hermes_high',\Tomaj\Hermes\Dispatcher::PRIORITY_HIGH);
+$driver->setupPriorityQueue('hermes_low', \Tomaj\Hermes\Dispatcher::PRIORITY_LOW);
+$driver->setupPriorityQueue('hermes_high', \Tomaj\Hermes\Dispatcher::PRIORITY_HIGH);
 
 $emitter = new Emitter($driver);