contamobi / CmobiRabbitmqBundle

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

Connection/ConnectionFactory.php

Spacing +3 added lines, -3 removed lines

@@ -62,10 +62,10 @@
             $this->parameters['user'],
             $this->parameters['password'],
             $this->parameters['vhost'],
-            false,      // insist
+            false, // insist
             'AMQPLAIN', // login_method
-            null,       // login_response
-            'en_US',    // locale
+            null, // login_response
+            'en_US', // locale
             $this->parameters['connection_timeout'],
             $this->parameters['read_write_timeout'],
             $this->parameters['ssl_context'],

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

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/Subscriber/Publisher.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
         $this->refreshChannel();
         $queueBag = new SubscriberQueueBag($this->getExchange(), $this->getExchangeType(), $this->getQueueName());
         $this->getChannel()->exchangeDeclare($queueBag->getExchangeDeclare());
-        $msg = new CmobiAMQPMessage((string) $data);
+        $msg = new CmobiAMQPMessage((string)$data);
         $this->getChannel()->basic_publish($msg, $queueBag->getExchange());
 
         $this->getChannel()->close();

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/Worker/Task.php

Spacing +2 added lines, -2 removed lines

@@ -34,13 +34,13 @@
     {
         $this->refreshChannel();
 
-        if (! $this->queueHasExists()) {
+        if (!$this->queueHasExists()) {
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
         }
         $queueBag = new WorkerQueueBag($this->getQueueName());
         $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'delivery_mode' => 2, // make message persistent
                 'priority' => $priority,

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

Transport/Rpc/RpcClient.php

Spacing +5 added lines, -5 removed lines

@@ -46,7 +46,7 @@ 
      */
     public function refreshChannel()
     {
-        if (! $this->connection->isConnected()) {
+        if (!$this->connection->isConnected()) {
             $this->connection->reconnect();
         }
         $this->channel = $this->connection->channel();
@@ -66,7 +66,7 @@ 
         $this->response = null;
         $this->refreshChannel();
 
-        if (! $this->queueHasExists()) {
+        if (!$this->queueHasExists()) {
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
         }
         $this->correlationId = $this->generateCorrelationId();
@@ -91,7 +91,7 @@ 
             [$this, 'onResponse']
         );
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'correlation_id' => $this->correlationId,
                 'reply_to' => $this->callbackQueue,
@@ -100,7 +100,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while (! $this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait(null, 0, ($expire / 1000));
         }
         $this->getChannel()->close();
@@ -166,7 +166,7 @@ 
     /** @return string */
     public function generateCorrelationId()
     {
-        return uniqid($this->getQueueName()) . Uuid::uuid4()->toString() . microtime();
+        return uniqid($this->getQueueName()).Uuid::uuid4()->toString().microtime();
     }
 
     /**