Evaneos / Burrow

src/Driver/PhpAmqpLibDriver.php

Doc Comments +1 added lines, -1 removed lines

@@ -278,7 +278,7 @@
     /**
      * @param AMQPMessage $message
      *
-     * @return array
+     * @return \string[]
      */
     private static function getHeaders(AMQPMessage $message)
     {

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

src/Message.php

Doc Comments +1 added lines, -1 removed lines

@@ -85,7 +85,7 @@
     }
 
     /**
-     * @return array
+     * @return string[]
      */
     public function getHeaders()
     {

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(),

examples/async-message-sender-pecl.php

Spacing +1 added lines, -1 removed lines

@@ -23,5 +23,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-pecl.php

Spacing +1 added lines, -1 removed lines

@@ -23,5 +23,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";

 }

examples/sync-message-worker.php

Indentation +4 added lines, -4 removed lines

@@ -24,10 +24,10 @@
 $logger->pushHandler(new StreamHandler('php://output', 0));

 

 $driver = DriverFactory::getDriver([

-   'host' => 'default',

-   'port' => '5672',

-   'user' => 'guest',

-   'pwd' => 'guest'

+    'host' => 'default',

+    'port' => '5672',

+    'user' => 'guest',

+    'pwd' => 'guest'

 ]);

 

 $handlerBuilder = new HandlerBuilder($driver);