Evaneos / Burrow

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";

src/Handler/HandlerBuilder.php

Spacing +2 added lines, -4 removed lines

@@ -117,14 +117,12 @@
         Assertion::notNull($this->sync, 'You must specify if the handler must be sync or async');
 
         $syncAsync = ($this->sync) ?
-            new SyncConsumerHandler($consumer, $this->driver) :
-            new AsyncConsumerHandler($consumer);
+            new SyncConsumerHandler($consumer, $this->driver) : new AsyncConsumerHandler($consumer);
 
         $ackHandler = new AckHandler($syncAsync, $this->driver, $this->requeueOnFailure);
 
         $handler = ($this->stopOnFailure) ?
-            new StopOnExceptionHandler($ackHandler) :
-            new ContinueOnExceptionHandler($ackHandler);
+            new StopOnExceptionHandler($ackHandler) : new ContinueOnExceptionHandler($ackHandler);
 
         $syncAsync->setLogger($this->logger);
         $handler->setLogger($this->logger);

src/Publisher/SyncPublisher.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
 
         $this->driver->consume(
             $replyTo,
-            function (Message $message) use ($replyTo, $correlationId, &$response) {
+            function(Message $message) use ($replyTo, $correlationId, &$response) {
                 if ($message->getCorrelationId() == $correlationId) {
                     $response = $message->getBody();
                     return QueueHandler::STOP_CONSUMING;

src/Daemon/QueueHandlingDaemon.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
 
         $this->driver->consume(
             $this->queueName,
-            function (Message $message) {
+            function(Message $message) {
                 $this->monitor->monitor($this, $message);
                 return $this->handler->handle($message);
             },

src/Driver/PeclAmqpDriver.php

Spacing +1 added lines, -1 removed lines

@@ -165,7 +165,7 @@
         $flags = $autoAck ? AMQP_AUTOACK : AMQP_NOPARAM;
 
         try {
-            $queue->consume(function (\AMQPEnvelope $message) use ($callback, $queueName) {
+            $queue->consume(function(\AMQPEnvelope $message) use ($callback, $queueName) {
 
                 $burrowMessage = new Message(
                     $message->getBody(),

src/Driver/PhpAmqpLibDriver.php

Spacing +3 added lines, -3 removed lines

@@ -57,7 +57,7 @@ 
         $durable = ($type === self::QUEUE_DURABLE);
         $exclusive = ($type === self::QUEUE_EXCLUSIVE);
 
-        list($name, , ) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false);
+        list($name,,) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false);
 
         return $name;
     }
@@ -72,7 +72,7 @@ 
      */
     public function declareExchange($exchangeName = '', $type = self::EXCHANGE_TYPE_FANOUT)
     {
-        list($name, , ) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false);
+        list($name,,) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false);
 
         return $name;
     }
@@ -166,7 +166,7 @@ 
             $autoAck,
             false,
             false,
-            function (AMQPMessage $message) use ($callback, $queueName) {
+            function(AMQPMessage $message) use ($callback, $queueName) {
                 $burrowMessage = new Message(
                     $message->getBody(),
                     '', // Impossible to retrieve here

Doc Comments +2 added lines, -2 removed lines

@@ -238,7 +238,7 @@ 
     }
 
     /**
-     * @param $timeout
+     * @param integer $timeout
      *
      * @throws \Exception
      */
@@ -288,7 +288,7 @@ 
     /**
      * @param AMQPMessage $message
      *
-     * @return array
+     * @return string[]
      */
     private static function getHeaders(AMQPMessage $message)
     {

examples/queue-config-amqplib.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-amqplib.php

Spacing +1 added lines, -1 removed lines

@@ -19,5 +19,5 @@
 $publisher = new AsyncPublisher($driver, 'xchange');

 

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

-    $publisher->publish('event #'.$i, '', ['test' => 'testValue']);

+    $publisher->publish('event #' . $i, '', ['test' => 'testValue']);

 }

examples/sync-message-sender.php

Indentation +4 added lines, -4 removed lines

@@ -15,10 +15,10 @@
 require_once __DIR__ . '/../vendor/autoload.php';

 

 $driver = DriverFactory::getDriver([

-   'host' => 'default',

-   'port' => '5672',

-   'user' => 'guest',

-   'pwd' => 'guest'

+    'host' => 'default',

+    'port' => '5672',

+    'user' => 'guest',

+    'pwd' => 'guest'

 ]);

 $publisher = new SyncPublisher($driver, 'xchange');

 

Spacing +1 added lines, -1 removed lines

@@ -19,5 +19,5 @@
 $publisher = new SyncPublisher($driver, 'xchange');

 

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

-    echo $publisher->publish('event #'.$i, '', ['test' => 'testValue'])."\n";

+    echo $publisher->publish('event #' . $i, '', ['test' => 'testValue']) . "\n";

 }