contamobi / CmobiRabbitmqBundle

Transport/Worker/Task.php

Spacing +2 added lines, -2 removed lines

@@ -34,13 +34,13 @@
     {
         $this->refreshChannel();
 
-        if (! $this->queueHasExists()) {
+        if (!$this->queueHasExists()) {
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
         }
         $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,

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/Subscriber/SubscriberBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
      */
     public function buildQueue($queueName, QueueServiceInterface $queueService, QueueBagInterface $queueBag)
     {
-        if (! $queueBag instanceof SubscriberQueueBag) {
+        if (!$queueBag instanceof SubscriberQueueBag) {
             throw new \Exception('Unsupported QueueBag');
         }
         $queue = new Queue($this->getConnectionManager(), $queueBag, $this->logger, $this->connectionName);

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/Subscriber/SubscriberQueueCallback.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);
         };
     }

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()
     {

Spacing +5 added lines, -5 removed lines

@@ -46,7 +46,7 @@ 
      */
     public function refreshChannel()
     {
-        if (! $this->connection->isConnected()) {
+        if (!$this->connection->isConnected()) {
             $this->connection->reconnect();
         }
         $this->channel = $this->connection->channel();
@@ -66,7 +66,7 @@ 
         $this->response = null;
         $this->refreshChannel();
 
-        if (! $this->queueHasExists()) {
+        if (!$this->queueHasExists()) {
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
         }
         $this->correlationId = $this->generateCorrelationId();
@@ -91,7 +91,7 @@ 
             [$this, 'onResponse']
         );
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'correlation_id' => $this->correlationId,
                 'reply_to' => $this->callbackQueue,
@@ -100,7 +100,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while (! $this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait(null, 0, ($expire / 1000));
         }
         $this->getChannel()->close();
@@ -166,7 +166,7 @@ 
     /** @return string */
     public function generateCorrelationId()
     {
-        return uniqid($this->getQueueName()) . Uuid::uuid4()->toString() . microtime();
+        return uniqid($this->getQueueName()).Uuid::uuid4()->toString().microtime();
     }
 
     /**