Evaneos / Burrow

src/RabbitMQ/AmqpSyncPublisher.php

Spacing +2 added lines, -2 removed lines

@@ -46,9 +46,9 @@
         $this->timeout = $timeout;
 
         $self = $this;
-        list($this->callbackQueue, , ) = $this->getChannel()->queue_declare('', false, false, true, false);
+        list($this->callbackQueue,,) = $this->getChannel()->queue_declare('', false, false, true, false);
         $this->getChannel()->basic_consume(
-            $this->callbackQueue, '', false, false, false, false, function (AMQPMessage $message) use ($self) {
+            $this->callbackQueue, '', false, false, false, false, function(AMQPMessage $message) use ($self) {
                 if ($message->get('correlation_id') == $self->getCorrelationId()) {
                     $self->setResponse($this->unescape($message->body));
                 }

src/RabbitMQ/AmqpTemplate.php

Spacing +3 added lines, -3 removed lines

@@ -50,7 +50,7 @@ 
     protected function escape($message)
     {
         $escapedMessage = $message;
-        switch($this->escapeMode) {
+        switch ($this->escapeMode) {
             case self::ESCAPE_MODE_SERIALIZE :
                 $escapedMessage = serialize($message);
                 break;
@@ -70,7 +70,7 @@ 
     protected function unescape($message)
     {
         $unescapedMessage = $message;
-        switch($this->escapeMode) {
+        switch ($this->escapeMode) {
             case self::ESCAPE_MODE_SERIALIZE :
                 $unescapedMessage = unserialize($message);
                 break;
@@ -83,7 +83,7 @@ 
 
     protected function getChannel()
     {
-        if(null === $this->channel) {
+        if (null === $this->channel) {
             $this->channel = $this->connection->channel();
         }
 

src/RabbitMQ/AbstractAmqpHandler.php

Spacing +3 added lines, -3 removed lines

@@ -122,7 +122,7 @@ 
         $self = $this;
 
         $this->getChannel()->basic_qos(null, 1, null);
-        $this->getChannel()->basic_consume($this->queueName, '', false, false, false, false, function (AMQPMessage $message) use ($self) {
+        $this->getChannel()->basic_consume($this->queueName, '', false, false, false, false, function(AMQPMessage $message) use ($self) {
             try {
                 $self->consume($message);
                 $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
@@ -132,7 +132,7 @@ 
                     $self->getLogger()
                         ->warning(
                             'Memory usage increased',
-                            array (
+                            array(
                                 'bytes_increased_by' => $currentMemory - $self->getMemory(),
                                 'bytes_current_memory' => $currentMemory
                             )
@@ -144,7 +144,7 @@ 
                 $message->delivery_info['channel']->basic_reject($message->delivery_info['delivery_tag'], $this->requeueOnFailure);
                 $self->getLogger()->error('Received exception', array('exception' => $e));
 
-                if($e instanceof ConsumerException) {
+                if ($e instanceof ConsumerException) {
                     $self->shutdown();
                 }
             }

examples/queue-config.php

Spacing +1 added lines, -1 removed lines

@@ -16,4 +16,4 @@
 $admin->declareExchange($exchangeName);

 $admin->declareAndBindQueue($exchangeName, $queueName);

 

-echo 'Added queue "'.$queueName.'" to exchange'."\n";

+echo 'Added queue "' . $queueName . '" to exchange' . "\n";

examples/async-message-sender.php

Spacing +1 added lines, -1 removed lines

@@ -12,5 +12,5 @@
 $publisher = new \Burrow\RabbitMQ\AmqpAsyncPublisher('127.0.0.1', 5672, 'guest', 'guest', 'xchange');

 

 for ($i = 0; $i < $argv[1]; ++$i) {

-    $publisher->publish('event #'.$i);

+    $publisher->publish('event #' . $i);

 }

examples/sync-message-sender.php

Spacing +1 added lines, -1 removed lines

@@ -12,5 +12,5 @@
 $publisher = new \Burrow\RabbitMQ\AmqpSyncPublisher('127.0.0.1', 5672, 'guest', 'guest', 'xchange');

 

 for ($i = 0; $i < $argv[1]; ++$i) {

-    echo $publisher->publish('event #'.$i)."\n";

+    echo $publisher->publish('event #' . $i) . "\n";

 }