eMAGTechLabs / RabbitMqBundle

RabbitMq/AmqpPartsHolder.php

Indentation +13 added lines, -13 removed lines

@@ -4,21 +4,21 @@
 
 class AmqpPartsHolder
 {
-	protected $parts;
+    protected $parts;
 
-	public function __construct()
-	{
-		$this->parts = array();
-	}
+    public function __construct()
+    {
+        $this->parts = array();
+    }
 
-	public function addPart($type, BaseAmqp $part)
-	{
-		$this->parts[$type][] = $part;
-	}
+    public function addPart($type, BaseAmqp $part)
+    {
+        $this->parts[$type][] = $part;
+    }
 
-	public function getParts($type)
-	{
+    public function getParts($type)
+    {
         $type = (string) $type;
-		return isset($this->parts[$type]) ? $this->parts[$type] : array();
-	}
+        return isset($this->parts[$type]) ? $this->parts[$type] : array();
+    }
 }

RabbitMq/RpcClient.php

Indentation +4 added lines, -4 removed lines

@@ -39,12 +39,12 @@
         }
 
         $msg = new AMQPMessage($msgBody, array('content_type' => 'text/plain',
-                                               'reply_to' => $this->directReplyTo
+                                                'reply_to' => $this->directReplyTo
                                                    ? 'amq.rabbitmq.reply-to' // On direct reply-to mode, use predefined queue name
                                                    : $this->getQueueName(),
-                                               'delivery_mode' => 1, // non durable
-                                               'expiration' => $expiration*1000,
-                                               'correlation_id' => $requestId));
+                                                'delivery_mode' => 1, // non durable
+                                                'expiration' => $expiration*1000,
+                                                'correlation_id' => $requestId));
 
         $this->getChannel()->basic_publish($msg, $server, $routingKey);
 

Command/DeleteCommand.php

Indentation +2 added lines, -2 removed lines

@@ -16,8 +16,8 @@
     protected function configure()
     {
         $this->addArgument('name', InputArgument::REQUIRED, 'Consumer Name')
-             ->setDescription('Delete a consumer\'s queue')
-             ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before deleting');
+                ->setDescription('Delete a consumer\'s queue')
+                ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before deleting');
 
         $this->setName('rabbitmq:delete');
     }

Command/PurgeConsumerCommand.php

Indentation +2 added lines, -2 removed lines

@@ -16,8 +16,8 @@
     protected function configure()
     {
         $this->addArgument('name', InputArgument::REQUIRED, 'Consumer Name')
-             ->setDescription('Purge a consumer\'s queue')
-             ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before purging');
+                ->setDescription('Purge a consumer\'s queue')
+                ->addOption('no-confirmation', null, InputOption::VALUE_NONE, 'Whether it must be confirmed before purging');
 
         $this->setName('rabbitmq:purge');
     }

Command/RpcServerCommand.php

Indentation +2 added lines, -2 removed lines

@@ -42,8 +42,8 @@
         }
 
         $this->getContainer()
-               ->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
-               ->start($amount);
+                ->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
+                ->start($amount);
 
         return 0;
     }