contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcQueueBag.php

Doc Comments +2 added lines, -2 removed lines

@@ -274,7 +274,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -282,7 +282,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getType()
     {

Transport/Rpc/RpcServerBuilder.php

Doc Comments +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
     }
 
     /**
-     * @param $queueName
+     * @param string $queueName
      * @param QueueServiceInterface $queueService
      * @param QueueBagInterface $queueBag
      * @return Queue

Transport/Worker/WorkerQueueBag.php

Doc Comments +5 added lines, -2 removed lines

@@ -10,6 +10,9 @@ 
     private $resolver;
     private $options;
 
+    /**
+     * @param string $queueName
+     */
     public function __construct(
         $queueName,
         $basicQos = 1,
@@ -187,7 +190,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -195,7 +198,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getType()
     {

Tests/Transport/Rpc/RpcClientOld.php

Doc Comments +1 added lines, -1 removed lines

@@ -129,7 +129,7 @@
 
     /**
      * @param string $msg
-     * @param null   $correlationId
+     * @param string   $correlationId
      *
      * @return CmobiAMQPMessage
      */

Transport/Rpc/RpcClient.php

Doc Comments +8 added lines, -4 removed lines

@@ -20,6 +20,10 @@ 
     private $correlationId;
     private $callbackQueue;
 
+    /**
+     * @param string $queueName
+     * @param string $fromName
+     */
     public function __construct($queueName, ConnectionManager $manager, $fromName)
     {
         $this->queueName = $queueName;
@@ -55,7 +59,7 @@ 
     }
 
     /**
-     * @param $data
+     * @param string $data
      * @param int $expire
      * @param int $priority
      * @throws QueueNotFoundException
@@ -148,7 +152,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)
     {
@@ -178,7 +182,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -186,7 +190,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchangeType()
     {

Transport/Subscriber/Publisher.php

Doc Comments +4 added lines

@@ -17,6 +17,10 @@
     private $exchange;
     private $exchangeType;
 
+    /**
+     * @param string $exchange
+     * @param string $fromName
+     */
     public function __construct(
         $exchange,
         $exchangeType = ExchangeType::FANOUT,

Transport/Subscriber/SubscriberBuilder.php

Doc Comments +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
     }
 
     /**
-     * @param $queueName
+     * @param string $queueName
      * @param QueueServiceInterface $queueService
      * @param QueueBagInterface $queueBag
      * @return Queue

Transport/Worker/Task.php

Doc Comments +6 added lines, -2 removed lines

@@ -16,6 +16,10 @@ 
     private $fromName;
     private $queueName;
 
+    /**
+     * @param string $queueName
+     * @param string $fromName
+     */
     public function __construct($queueName, ConnectionManager $manager, $fromName)
     {
         $this->queueName = $queueName;
@@ -107,7 +111,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -115,7 +119,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchangeType()
     {

Transport/Worker/WorkerBuilder.php

Doc Comments +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
     }
 
     /**
-     * @param $queueName
+     * @param string $queueName
      * @param QueueServiceInterface $queueService
      * @param QueueBagInterface $queueBag
      * @return Queue