contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcServerBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,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);

Transport/PubSub/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);

Transport/Worker/WorkerBuilder.php

Spacing +1 added lines, -1 removed lines

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