eMAGTechLabs / RabbitMqBundle

RabbitMq/MultipleConsumer.php

Spacing +2 added lines, -2 removed lines

@@ -64,7 +64,7 @@ 
             //PHP 5.3 Compliant
             $currentObject = $this;
 
-            $this->getChannel()->basic_consume($name, $this->getQueueConsumerTag($name), false, false, false, false, function (AMQPMessage $msg) use($currentObject, $name) {
+            $this->getChannel()->basic_consume($name, $this->getQueueConsumerTag($name), false, false, false, false, function(AMQPMessage $msg) use($currentObject, $name) {
                 $currentObject->processQueueMessage($name, $msg);
             });
         }
@@ -73,7 +73,7 @@ 
     protected function queueDeclare()
     {
         foreach ($this->queues as $name => $options) {
-            list($queueName, ,) = $this->getChannel()->queue_declare($name, $options['passive'],
+            list($queueName,,) = $this->getChannel()->queue_declare($name, $options['passive'],
                 $options['durable'], $options['exclusive'],
                 $options['auto_delete'], $options['nowait'],
                 $options['arguments'], $options['ticket']);

RabbitMq/Consumer.php

Spacing +1 added lines, -1 removed lines

@@ -268,7 +268,7 @@
     {
         if ($this->gracefulMaxExecutionDateTime) {
             $allowedExecutionDateInterval = $this->gracefulMaxExecutionDateTime->diff(new \DateTime());
-            $allowedExecutionSeconds =  $allowedExecutionDateInterval->days * 86400
+            $allowedExecutionSeconds = $allowedExecutionDateInterval->days * 86400
                 + $allowedExecutionDateInterval->h * 3600
                 + $allowedExecutionDateInterval->i * 60
                 + $allowedExecutionDateInterval->s;

RabbitMq/BatchConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -280,7 +280,7 @@
     private function addMessage(AMQPMessage $message)
     {
         $this->batchCounter++;
-        $this->messages[(int)$message->delivery_info['delivery_tag']] = $message;
+        $this->messages[(int) $message->delivery_info['delivery_tag']] = $message;
     }
 
     /**

RabbitMq/BaseAmqp.php

Spacing +1 added lines, -1 removed lines

@@ -218,7 +218,7 @@
     protected function queueDeclare()
     {
         if ($this->queueOptions['declare']) {
-            list($queueName, ,) = $this->getChannel()->queue_declare($this->queueOptions['name'], $this->queueOptions['passive'],
+            list($queueName,,) = $this->getChannel()->queue_declare($this->queueOptions['name'], $this->queueOptions['passive'],
                 $this->queueOptions['durable'], $this->queueOptions['exclusive'],
                 $this->queueOptions['auto_delete'], $this->queueOptions['nowait'],
                 $this->queueOptions['arguments'], $this->queueOptions['ticket']);

RabbitMq/RpcClient.php

Spacing +2 added lines, -2 removed lines

@@ -43,7 +43,7 @@ 
                                                    ? 'amq.rabbitmq.reply-to' // On direct reply-to mode, use predefined queue name
                                                    : $this->getQueueName(),
                                                'delivery_mode' => 1, // non durable
-                                               'expiration' => $expiration*1000,
+                                               'expiration' => $expiration * 1000,
                                                'correlation_id' => $requestId));
 
         $this->getChannel()->basic_publish($msg, $server, $routingKey);
@@ -91,7 +91,7 @@ 
     protected function getQueueName()
     {
         if (null === $this->queueName) {
-            list($this->queueName, ,) = $this->getChannel()->queue_declare("", false, false, true, false);
+            list($this->queueName,,) = $this->getChannel()->queue_declare("", false, false, true, false);
         }
 
         return $this->queueName;

RabbitMq/Producer.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
             $msg->set('application_headers', $headersTable);
         }
 
-        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string)$routingKey);
+        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string) $routingKey);
         $this->logger->debug('AMQP message published', array(
             'amqp' => array(
                 'body' => $msgBody,

RabbitMq/AMQPConnectionFactory.php

Spacing +9 added lines, -9 removed lines

@@ -44,7 +44,7 @@ 
         $this->parameters = array_merge($this->parameters, $parameters);
         $this->parameters = $this->parseUrl($this->parameters);
         if (is_array($this->parameters['ssl_context'])) {
-            $this->parameters['ssl_context'] = ! empty($this->parameters['ssl_context'])
+            $this->parameters['ssl_context'] = !empty($this->parameters['ssl_context'])
                 ? stream_context_create(array('ssl' => $this->parameters['ssl_context']))
                 : null;
         }
@@ -65,17 +65,17 @@ 
             return $ref->newInstanceArgs($this->parameters['constructor_args']);
         }
 
-        if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class , 'PhpAmqpLib\Connection\AMQPSocketConnection')) {
+        if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class, 'PhpAmqpLib\Connection\AMQPSocketConnection')) {
             return new $this->class(
                 $this->parameters['host'],
                 $this->parameters['port'],
                 $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
                 isset($this->parameters['read_timeout']) ? $this->parameters['read_timeout'] : $this->parameters['read_write_timeout'],
                 $this->parameters['keepalive'],
                 isset($this->parameters['write_timeout']) ? $this->parameters['write_timeout'] : $this->parameters['read_write_timeout'],
@@ -88,10 +88,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'],
@@ -125,7 +125,7 @@ 
             $parameters['host'] = urldecode($url['host']);
         }
         if (isset($url['port'])) {
-            $parameters['port'] = (int)$url['port'];
+            $parameters['port'] = (int) $url['port'];
         }
         if (isset($url['user'])) {
             $parameters['user'] = urldecode($url['user']);

RabbitMq/DynamicConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -4,7 +4,7 @@
 
 use OldSound\RabbitMqBundle\Provider\QueueOptionsProviderInterface;
 
-class DynamicConsumer extends Consumer{
+class DynamicConsumer extends Consumer {
 
     /**
      * Queue provider

RabbitMq/RpcServer.php

Spacing +2 added lines, -2 removed lines

@@ -11,7 +11,7 @@ 
     public function initServer($name)
     {
         $this->setExchangeOptions(array('name' => $name, 'type' => 'direct'));
-        $this->setQueueOptions(array('name' => $name . '-queue'));
+        $this->setQueueOptions(array('name' => $name.'-queue'));
     }
 
     public function processMessage(AMQPMessage $msg)
@@ -24,7 +24,7 @@ 
             $this->consumed++;
             $this->maybeStopConsumer();
         } catch (\Exception $e) {
-            $this->sendReply('error: ' . $e->getMessage(), $msg->get('reply_to'), $msg->get('correlation_id'));
+            $this->sendReply('error: '.$e->getMessage(), $msg->get('reply_to'), $msg->get('correlation_id'));
         }
     }