contamobi / CmobiRabbitmqBundle

Transport/PubSub/Publisher.php

Doc Comments +3 added lines

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

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
         $this->refreshChannel();
         $queueBag = new SubscriberQueueBag($this->getExchange(), $this->getExchangeType(), $this->getQueueName());
         $this->getChannel()->exchangeDeclare($queueBag->getExchangeDeclare());
-        $msg = new CmobiAMQPMessage((string) $data);
+        $msg = new CmobiAMQPMessage((string)$data);
         $this->getChannel()->basic_publish($msg, $queueBag->getExchange());
 
         $this->getChannel()->close();

Transport/PubSub/SubscriberBuilder.php

Doc Comments +4 added lines, -1 removed lines

@@ -17,6 +17,9 @@ 
     private $logger;
     private $parameters;
 
+    /**
+     * @param string $exchangeName
+     */
     public function __construct(
         $exchangeName,
         $exchangeType = ExchangeType::FANOUT,
@@ -34,7 +37,7 @@ 
     }
 
     /**
-     * @param $queueName
+     * @param string $queueName
      * @param QueueServiceInterface $queueService
      *
      * @return Queue

Transport/Rpc/RpcClient.php

Doc Comments +7 added lines, -4 removed lines

@@ -18,6 +18,9 @@ 
     private $correlationId;
     private $callbackQueue;
 
+    /**
+     * @param string $queueName
+     */
     public function __construct($queueName, ConnectionManager $manager, $fromName = '')
     {
         $this->queueName = $queueName;
@@ -52,7 +55,7 @@ 
     }
 
     /**
-     * @param $data
+     * @param string $data
      * @param int $expire
      * @param int $priority
      */
@@ -118,7 +121,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)
     {
@@ -148,7 +151,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -156,7 +159,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchangeType()
     {

Spacing +1 added lines, -1 removed lines

@@ -76,7 +76,7 @@
             [$this, 'onResponse']
         );
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'correlation_id' => $this->correlationId,
                 'reply_to' => $this->callbackQueue,

Transport/Worker/Task.php

Doc Comments +5 added lines, -2 removed lines

@@ -15,6 +15,9 @@ 
     private $fromName;
     private $queueName;
 
+    /**
+     * @param string $queueName
+     */
     public function __construct($queueName, ConnectionManager $manager, $fromName = '')
     {
         $this->queueName = $queueName;
@@ -87,7 +90,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -95,7 +98,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchangeType()
     {

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
         $queueBag = new WorkerQueueBag($this->getQueueName());
         $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'delivery_mode' => 2, // make message persistent
                 'priority' => $priority,

Transport/Worker/WorkerBuilder.php

Doc Comments +1 added lines, -1 removed lines

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

Transport/Worker/WorkerQueueBag.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/Worker/WorkerQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $this->getQueueService()->handle($message);
 
             $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);

Tests/Transport/PubSub/SubscriberBuilderTest.php

Indentation +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
     {
         $subscriberBuilder = new SubscriberBuilder(
             'test_exchange',
-             ExchangeType::FANOUT,
+                ExchangeType::FANOUT,
             $this->getConnectionManagerMock(),
             $this->getLoggerMock(),
             []

Tests/Transport/Rpc/RpcClientTest.php

Doc Comments +1 added lines, -1 removed lines

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