CMProductions / queues

src/Infrastructure/AmqpLib/v26/RabbitMQ/Queue/MessageHandler.php

Unused Use Statements -1 removed lines

@@ -10,7 +10,6 @@
 
 use Domain\Queue\JSONMessageFactory;
 use PhpAmqpLib\Message\AMQPMessage;
-use Psr\Log\LoggerInterface;
 
 class MessageHandler
 {

src/Infrastructure/AmqpLib/v26/RabbitMQ/Queue/DelayedQueueWriter.php

Spacing +10 added lines, -10 removed lines

@@ -68,7 +68,7 @@ 
     {
         $this->delay = $delay;
         $this->exchangeName = $exchangeName;
-        $this->delayedExchangeName = self::DELAY_QUEUE_PREFIX.$this->delay.$this->exchangeName;
+        $this->delayedExchangeName = self::DELAY_QUEUE_PREFIX . $this->delay . $this->exchangeName;
         $this->logger = $logger;
         $this->channel = $channel;
     }
@@ -82,15 +82,15 @@ 
     {
         $this->initialize();
         try {
-            foreach($messages as $message) {
+            foreach ($messages as $message) {
                 $encodedMessage = json_encode($message);
                 $this->logger->debug('Writing:' . $encodedMessage);
                 $msg = new AMQPMessage($encodedMessage, array('delivery_mode' => 2));
                 $this->channel->batch_basic_publish($msg, $this->delayedExchangeName, $message->getName());
             }
             $this->channel->publish_batch();
-        } catch(\Exception $exception) {
-            $this->logger->error('Error writing delayed messages: '.$exception->getMessage());
+        } catch (\Exception $exception) {
+            $this->logger->error('Error writing delayed messages: ' . $exception->getMessage());
             throw new WriterException($exception->getMessage(), $exception->getCode());
         }
     }
@@ -100,13 +100,13 @@ 
      */
     protected function initialize()
     {
-        try{
-            $delayedQueue = self::DELAY_QUEUE_PREFIX.$this->delay.'Queue';
+        try {
+            $delayedQueue = self::DELAY_QUEUE_PREFIX . $this->delay . 'Queue';
 
-            $this->logger->info('Creating delayed exchange '.$this->delayedExchangeName);
+            $this->logger->info('Creating delayed exchange ' . $this->delayedExchangeName);
             // Delay Queue
             $this->channel->exchange_declare($this->delayedExchangeName, 'fanout', false, true, true);
-            $this->logger->info('Creating delayed queue '.$delayedQueue);
+            $this->logger->info('Creating delayed queue ' . $delayedQueue);
             $this->channel->queue_declare(
                 $delayedQueue,
                 false,
@@ -121,8 +121,8 @@ 
                 ]
             );
             $this->channel->queue_bind($delayedQueue, $this->delayedExchangeName);
-        } catch(\Exception $exception) {
-            $this->logger->error('Error configuring delayed queues: '.$exception->getMessage());
+        } catch (\Exception $exception) {
+            $this->logger->error('Error configuring delayed queues: ' . $exception->getMessage());
             throw new WriterException($exception->getMessage(), $exception->getCode());
         }
     }