contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcClient.php

Doc Comments +8 added lines, -4 removed lines

@@ -22,6 +22,10 @@ 
     private $correlationId;
     private $callbackQueue;
 
+    /**
+     * @param string $queueName
+     * @param string $fromName
+     */
     public function __construct($queueName, ConnectionManager $manager, $fromName, $connectionName = 'default')
     {
         $this->connectionName = $connectionName;
@@ -43,7 +47,7 @@ 
     }
 
     /**
-     * @param $data
+     * @param string $data
      * @param int $expire
      * @param int $priority
      * @throws QueueNotFoundException
@@ -133,7 +137,7 @@ 
     /**
      * @todo unecessary method set, its only exists to run tests whitout stay jailed in infinite while waiting response.
      *
-     * @param $content
+     * @param string $content
      */
     public function setResponse($content)
     {
@@ -163,7 +167,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -171,7 +175,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchangeType()
     {

Unused Use Statements -2 removed lines

@@ -3,13 +3,11 @@
 namespace Cmobi\RabbitmqBundle\Transport\Rpc;
 
 use Cmobi\RabbitmqBundle\Connection\CmobiAMQPChannel;
-use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnection;
 use Cmobi\RabbitmqBundle\Connection\CmobiAMQPConnectionInterface;
 use Cmobi\RabbitmqBundle\Connection\ConnectionManager;
 use Cmobi\RabbitmqBundle\Queue\CmobiAMQPMessage;
 use Cmobi\RabbitmqBundle\Queue\QueueProducerInterface;
 use Cmobi\RabbitmqBundle\Transport\Exception\QueueNotFoundException;
-use PhpAmqpLib\Exception\AMQPTimeoutException;
 use PhpAmqpLib\Message\AMQPMessage;
 use Ramsey\Uuid\Uuid;