contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcQueueCallback.php

Spacing +2 added lines, -2 removed lines

@@ -29,11 +29,11 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $response = $this->getQueueService()->handle($message);
 
             $amqpResponse = new CmobiAMQPMessage(
-                (string) $response,
+                (string)$response,
                 ['correlation_id' => $message->get('correlation_id')]
             );
 

Transport/PubSub/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);
 
             $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);

Tests/Queue/QueueTest.php

Spacing +1 added lines, -1 removed lines

@@ -76,7 +76,7 @@
             ->disableOriginalConstructor()
             ->getMock();
         $callbackMock->method('toClosure')
-            ->willReturn(function () {});
+            ->willReturn(function() {});
 
         return $callbackMock;
     }

Transport/PubSub/SubscriberBuilder.php

Doc Comments +1 added lines, -1 removed lines

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

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);

Transport/PubSub/SubscriberQueueBag.php

Doc Comments +6 added lines, -2 removed lines

@@ -8,6 +8,10 @@ 
 {
     private $options;
 
+    /**
+     * @param string $exchange
+     * @param string $queueName
+     */
     public function __construct(
         $exchange,
         $type = ExchangeType::FANOUT,
@@ -55,7 +59,7 @@ 
     }
 
     /**
-     * @return string|mixed
+     * @return string
      */
     public function getExchange()
     {
@@ -352,7 +356,7 @@ 
     }
 
     /**
-     * @return string|mixed
+     * @return string
      */
     public function getQueue()
     {

Transport/Worker/WorkerQueueBag.php

Doc Comments +5 added lines, -2 removed lines

@@ -8,6 +8,9 @@ 
 {
     private $options;
 
+    /**
+     * @param string $queue
+     */
     public function __construct(
         $queue,
         $basicQos = 1,
@@ -273,7 +276,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getExchange()
     {
@@ -281,7 +284,7 @@ 
     }
 
     /**
-     * @return string
+     * @return boolean
      */
     public function getType()
     {