Evaneos / Burrow

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/CLI/InitCommand.php

Doc Comments +3 added lines, -3 removed lines

@@ -140,7 +140,7 @@ 
     }
 
     /**
-     * @param array $exchangeInformation
+     * @param string[] $exchangeInformation
      *
      * @throws AssertionFailedException
      */
@@ -180,7 +180,7 @@ 
     }
 
     /**
-     * @param array           $exchangeInformation
+     * @param string[]           $exchangeInformation
      * @param OutputInterface $output
      */
     private function bindExchange(array $exchangeInformation, OutputInterface $output)
@@ -207,7 +207,7 @@ 
 
     /**
      * @param string          $exchangeName
-     * @param array           $queueInformation
+     * @param string[]           $queueInformation
      * @param OutputInterface $output
      */
     private function bindQueue(

src/Daemon/QueueHandlingDaemon.php

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

@@ -3,17 +3,17 @@
 namespace Burrow\Daemon;
 
 use Burrow\ConsumeOptions;
+use Burrow\Driver;
 use Burrow\Event\DaemonStarted;
 use Burrow\Event\DaemonStopped;
 use Burrow\Event\MessageConsumed;
 use Burrow\Event\MessageReceived;
 use Burrow\Event\NullEmitter;
+use Burrow\Message;
+use Burrow\QueueHandler;
 use Evaneos\Daemon\Daemon;
 use Evaneos\Daemon\DaemonMonitor;
-use Burrow\Driver;
-use Burrow\Message;
 use Evaneos\Daemon\Monitor\NullMonitor;
-use Burrow\QueueHandler;
 use League\Event\Emitter;
 use League\Event\EmitterInterface;
 use Psr\Log\LoggerAwareInterface;

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);
 

src/Driver/PeclAmqpDriver.php

Spacing +1 added lines, -1 removed lines

@@ -202,7 +202,7 @@
         $flags = $autoAck ? AMQP_AUTOACK : AMQP_NOPARAM;
         $consumerTag = self::generateConsumerTag();
         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

Doc Comments +5 added lines, -2 removed lines

@@ -253,7 +253,7 @@ 
     }
 
     /**
-     * @param $timeout
+     * @param integer $timeout
      *
      * @throws Exception
      */
@@ -302,7 +302,7 @@ 
     /**
      * @param AMQPMessage $message
      *
-     * @return array
+     * @return string[]
      *
      * @throws \OutOfBoundsException
      */
@@ -338,6 +338,9 @@ 
             $message->get(self::REPLY_TO) : '';
     }
 
+    /**
+     * @param string $exchangeName
+     */
     private function retryPublish($exchangeName, Message $message)
     {
         $this->retryPublish = true;

Spacing +3 added lines, -3 removed lines

@@ -64,7 +64,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;
     }
@@ -79,7 +79,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;
     }
@@ -181,7 +181,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