contamobi / CmobiRabbitmqBundle

DependencyInjection/CmobiRabbitmqExtension.php

Spacing +1 added lines, -1 removed lines

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

Tests/app/AppKernel.php

Spacing +1 added lines, -1 removed lines

@@ -15,6 +15,6 @@
 
     public function registerContainerConfiguration(LoaderInterface $loader)
     {
-        $loader->load(__DIR__ . '/config/config.yml');
+        $loader->load(__DIR__.'/config/config.yml');
     }
 }
\ No newline at end of file

Transport/Rpc/RpcClient.php

Spacing +5 added lines, -5 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function onResponse(AMQPMessage $rep)
     {
-        if($rep->get('correlation_id') === $this->correlationId) {
+        if ($rep->get('correlation_id') === $this->correlationId) {
             $this->response = $rep->getBody();
         }
     }
@@ -43,7 +43,7 @@ 
     {
         $connection = $this->connectionManager->getConnection();
 
-        if (! $connection->isConnected()) {
+        if (!$connection->isConnected()) {
             $connection->reconnect();
         }
         $this->channel = $connection->channel();
@@ -66,7 +66,7 @@ 
         $queueBag->setArguments([
             'x-expires' => ['I', $expire]
         ]);
-        list($callbackQueue, ,) = $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
+        list($callbackQueue,,) = $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
         $this->callbackQueue = $callbackQueue;
         $consumeQueueBag = new RpcQueueBag($callbackQueue);
 
@@ -84,7 +84,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while(! $this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait(null, 0, ($expire / 1000));
         }
         $this->getChannel()->close();
@@ -136,7 +136,7 @@ 
     /** @return string */
     public function generateCorrelationId()
     {
-        return uniqid($this->getQueueName()) . microtime();
+        return uniqid($this->getQueueName()).microtime();
     }
 
     /**

Transport/Rpc/RpcQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $response = $this->getQueueService()->handle($message);
 
             $amqpResponse = new CmobiAMQPMessage(

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

Transport/PubSub/Publisher.php

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
         /** @var CmobiAMQPConnectionInterface $connection */
         $connection = $this->connectionManager->getConnection();
 
-        if (! $connection->isConnected()) {
+        if (!$connection->isConnected()) {
             $connection->reconnect();
         }
         $this->channel = $connection->channel();

Transport/PubSub/ExchangeType.php

Spacing +1 added lines, -1 removed lines

@@ -5,6 +5,6 @@
 class ExchangeType
 {
     const FANOUT = 'fanout';
-    const DIRECT  = 'direct';
+    const DIRECT = 'direct';
     const TOPIC = 'topic';
 }
\ No newline at end of file

Transport/Worker/Task.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
         /** @var CmobiAMQPConnectionInterface $connection */
         $connection = $this->connectionManager->getConnection();
 
-        if (! $connection->isConnected()) {
+        if (!$connection->isConnected()) {
             $connection->reconnect();
         }
         $this->channel = $connection->channel();

Transport/Worker/WorkerQueueCallback.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']);