tomaj / hermes

src/Driver/RabbitMqDriver.php

Spacing +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
             true,
             false,
             false,
-            function ($rabbitMessage) use ($callback) {
+            function($rabbitMessage) use ($callback) {
                 $message = $this->serializer->unserialize($rabbitMessage->body);
                 $callback($message);
             }

examples/rabbitmq/emitter.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Tomaj\Hermes\Message;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__.'/../../vendor/autoload.php';
 
 
 $queueName = 'hermes_queue';

src/Driver/LazyRabbitMqDriver.php

Spacing +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
             true,
             false,
             false,
-            function ($rabbitMessage) use ($callback) {
+            function($rabbitMessage) use ($callback) {
                 $message = $this->serializer->unserialize($rabbitMessage->body);
                 $callback($message);
             }

src/Dispatcher.php

Spacing +3 added lines, -3 removed lines

@@ -71,7 +71,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;
@@ -89,7 +89,7 @@ 
     public function handle()
     {
         try {
-            $this->driver->wait(function (MessageInterface $message) {
+            $this->driver->wait(function(MessageInterface $message) {
                 $this->log(
                     LogLevel::INFO,
                     "Start handle message #{$message->getId()} ({$message->getType()})",
@@ -165,7 +165,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]
             );
             Debugger::log($e, Debugger::EXCEPTION);

examples/rabbitmq/processor.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Tomaj\Hermes\Message;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__.'/../../vendor/autoload.php';
 
 
 $queueName = 'hermes_queue';

examples/zmq/processor.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Tomaj\Hermes\Message;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__.'/../../vendor/autoload.php';
 
 
 $queueName = 'hermes_queue';

examples/zmq/emitter.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Tomaj\Hermes\Message;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__.'/../../vendor/autoload.php';
 
 
 $queueName = 'hermes_queue';

examples/redis/processor.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Tomaj\Hermes\Message;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__.'/../../vendor/autoload.php';
 
 
 $queueName = 'hermes_queue';

examples/redis/emitter.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
 use Tomaj\Hermes\Message;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
 
-require_once __DIR__ . '/../../vendor/autoload.php';
+require_once __DIR__.'/../../vendor/autoload.php';
 
 
 $queueName = 'hermes_queue';