Evaneos / Burrow

src/Driver/PeclAmqpDriver.php

Spacing +1 added lines, -1 removed lines

@@ -165,7 +165,7 @@
         $flags = $autoAck ? AMQP_AUTOACK : AMQP_NOPARAM;
 
         try {
-            $queue->consume(function (\AMQPEnvelope $message) use ($callback, $queueName) {
+            $queue->consume(function(\AMQPEnvelope $message) use ($callback, $queueName) {
 
                 $burrowMessage = new Message(
                     $message->getBody(),

src/Driver/PhpAmqpLibDriver.php

Spacing +3 added lines, -3 removed lines

@@ -57,7 +57,7 @@ 
         $durable = ($type === self::QUEUE_DURABLE);
         $exclusive = ($type === self::QUEUE_EXCLUSIVE);
 
-        list($name, , ) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false);
+        list($name,,) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false);
 
         return $name;
     }
@@ -72,7 +72,7 @@ 
      */
     public function declareExchange($exchangeName = '', $type = self::EXCHANGE_TYPE_FANOUT)
     {
-        list($name, , ) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false);
+        list($name,,) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false);
 
         return $name;
     }
@@ -166,7 +166,7 @@ 
             $autoAck,
             false,
             false,
-            function (AMQPMessage $message) use ($callback, $queueName) {
+            function(AMQPMessage $message) use ($callback, $queueName) {
                 $burrowMessage = new Message(
                     $message->getBody(),
                     '', // Impossible to retrieve here

src/Publisher/SyncPublisher.php

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
 
         $this->driver->consume(
             $replyTo,
-            function (Message $message) use ($correlationId, &$response) {
+            function(Message $message) use ($correlationId, &$response) {
                 if ($message->getCorrelationId() == $correlationId) {
                     $response = $message->getBody();
                     return QueueHandler::STOP_CONSUMING;

src/Handler/HandlerBuilder.php

Spacing +3 added lines, -6 removed lines

@@ -135,19 +135,16 @@
 
         // Sync
         $handler = $this->sync ?
-            new SyncConsumerHandler($consumer, $this->driver) :
-            new AsyncConsumerHandler($consumer);
+            new SyncConsumerHandler($consumer, $this->driver) : new AsyncConsumerHandler($consumer);
         $handler->setLogger($this->logger);
 
         // Ack
         $handler = $this->autoAck ?
-            $handler :
-            new AckHandler($handler, $this->driver, $this->requeueOnFailure);
+            $handler : new AckHandler($handler, $this->driver, $this->requeueOnFailure);
 
         // Stop / Continue
         $handler = $this->stopOnFailure ?
-            new StopOnExceptionHandler($handler) :
-            new ContinueOnExceptionHandler($handler);
+            new StopOnExceptionHandler($handler) : new ContinueOnExceptionHandler($handler);
         $handler->setLogger($this->logger);
 
         return $handler;

src/Daemon/QueueHandlingDaemon.php

Spacing +1 added lines, -1 removed lines

@@ -77,7 +77,7 @@
 
         $this->driver->consume(
             $this->queueName,
-            function (Message $message) {
+            function(Message $message) {
                 $this->eventEmitter->emit(new MessageReceived());
                 $this->monitor->monitor($this, $message);