contamobi / CmobiRabbitmqBundle

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

Spacing +1 added lines, -1 removed lines

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

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

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

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

DependencyInjection/CmobiRabbitmqExtension.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 {
     public function load(array $configs, ContainerBuilder $container)
     {
-        $fileLocator = new FileLocator(__DIR__ . '/../Resources/config');
+        $fileLocator = new FileLocator(__DIR__.'/../Resources/config');
         $loader = new YamlFileLoader($container, $fileLocator);
         $loader->load('rabbitmq.yml');
 

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