Evaneos / Burrow

src/Handler/HandlerBuilder.php

Spacing +2 added lines, -4 removed lines

@@ -117,14 +117,12 @@
         Assertion::notNull($this->sync, 'You must specify if the handler must be sync or async');
 
         $syncAsync = ($this->sync) ?
-            new SyncConsumerHandler($consumer, $this->driver) :
-            new AsyncConsumerHandler($consumer);
+            new SyncConsumerHandler($consumer, $this->driver) : new AsyncConsumerHandler($consumer);
 
         $ackHandler = new AckHandler($syncAsync, $this->driver, $this->requeueOnFailure);
 
         $handler = ($this->stopOnFailure) ?
-            new StopOnExceptionHandler($ackHandler) :
-            new ContinueOnExceptionHandler($ackHandler);
+            new StopOnExceptionHandler($ackHandler) : new ContinueOnExceptionHandler($ackHandler);
 
         $syncAsync->setLogger($this->logger);
         $handler->setLogger($this->logger);

src/Daemon/QueueHandlingDaemon.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
 
         $this->driver->consume(
             $this->queueName,
-            function (Message $message) {
+            function(Message $message) {
                 $this->monitor->monitor($this, $message);
                 return $this->handler->handle($message);
             },

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

Doc Comments +2 added lines, -2 removed lines

@@ -238,7 +238,7 @@ 
     }
 
     /**
-     * @param $timeout
+     * @param integer $timeout
      *
      * @throws \Exception
      */
@@ -288,7 +288,7 @@ 
     /**
      * @param AMQPMessage $message
      *
-     * @return array
+     * @return string[]
      */
     private static function getHeaders(AMQPMessage $message)
     {

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;