Evaneos / Burrow

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;

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;

src/Driver/DriverFactory.php

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

@@ -4,9 +4,9 @@
 
 use Burrow\Connection\PhpAmqpLib\AMQPLazySSLConnection;
 use Burrow\Driver;
-use PhpAmqpLib\Connection\AbstractConnection;
 use PhpAmqpLib\Connection\AMQPLazyConnection;
 use PhpAmqpLib\Connection\AMQPStreamConnection;
+use PhpAmqpLib\Connection\AbstractConnection;
 
 class DriverFactory
 {