contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcServerBuilder.php

Doc Comments +1 added lines, -1 removed lines

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

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