alchemy-fr / queue-component

src/Amqp/AmqpMessageQueue.php

Spacing +2 added lines, -2 removed lines

@@ -34,7 +34,7 @@ 
         $attributes = ['correlation_id' => $message->getCorrelationId()];
         $result = $this->exchange->publish($message->getBody(), $this->queue->getName(), AMQP_DURABLE, $attributes);
 
-        if (! $result) {
+        if (!$result) {
             throw new MessagePublishingException();
         }
     }
@@ -44,7 +44,7 @@ 
      */
     public function handle(MessageHandlerResolver $resolver)
     {
-        $this->queue->consume(function (\AMQPEnvelope $envelope) use ($resolver) {
+        $this->queue->consume(function(\AMQPEnvelope $envelope) use ($resolver) {
             $message = new Message($envelope->getBody(), $envelope->getCorrelationId());
             $handler = $resolver->resolveHandler($message);