alchemy-fr / queue-component

src/Amqp/AmqpMessageQueue.php

Spacing +5 added lines, -5 removed lines

@@ -52,12 +52,12 @@ 
      */
     public function publish(Message $message)
     {
-        $this->logger->debug('Publishing message to queue: ' . $this->queue->getName());
+        $this->logger->debug('Publishing message to queue: '.$this->queue->getName());
 
         $attributes = ['correlation_id' => $message->getCorrelationId()];
         $result = $this->exchange->publish($message->getBody(), $this->queue->getName(), AMQP_DURABLE, $attributes);
 
-        if (! $result) {
+        if (!$result) {
             throw new MessagePublishingException();
         }
     }
@@ -67,9 +67,9 @@ 
      */
     public function handle(MessageHandlerResolver $resolver)
     {
-        $this->logger->debug('Consuming messages from AMQP queue: ' . $this->queue->getName());
+        $this->logger->debug('Consuming messages from AMQP queue: '.$this->queue->getName());
 
-        $this->queue->consume(function (\AMQPEnvelope $envelope, \AMQPQueue $queue) use ($resolver) {
+        $this->queue->consume(function(\AMQPEnvelope $envelope, \AMQPQueue $queue) use ($resolver) {
             $message = new Message($envelope->getBody(), $envelope->getCorrelationId());
             $handler = $resolver->resolveHandler($message);
 
@@ -78,7 +78,7 @@ 
                 $handler->handle($message);
                 $this->ackMessage($queue, $envelope);
             } catch (MessageHandlingException $exception) {
-                $this->logger->error('Caught exception while handling message: ' . $exception->getMessage());
+                $this->logger->error('Caught exception while handling message: '.$exception->getMessage());
                 $this->nackMessage($queue, $envelope);
             }
 

src/Amqp/AmqpMessageQueueFactory.php

Doc Comments +2 added lines, -2 removed lines

@@ -63,7 +63,7 @@ 
     }
 
     /**
-     * @param $name
+     * @param string $name
      * @return MessageQueue
      */
     public function getNamedQueue($name)
@@ -77,7 +77,7 @@ 
      * @param \AMQPExchange $exchange
      * @param $queueName
      * @param string $errorExchangeName
-     * @return \AMQPQueue
+     * @return AmqpMessageQueue
      */
     private function buildQueue(\AMQPExchange $exchange, $queueName, $errorExchangeName = '')
     {

src/MessageQueueRegistry.php

Spacing +1 added lines, -1 removed lines

@@ -71,7 +71,7 @@
             return $this->queues[$queueName] = $queue;
         }
 
-        throw new \RuntimeException('Queue is not registered: ' . $queueName);
+        throw new \RuntimeException('Queue is not registered: '.$queueName);
     }
 
     /**