CMProductions / queues

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

Spacing +7 added lines, -7 removed lines

@@ -64,8 +64,8 @@ 
         $this->initialize();
         try {
             $messagesWithDelay = [];
-            foreach($messages as $message) {
-                if($message->getDelay() > 0) {
+            foreach ($messages as $message) {
+                if ($message->getDelay() > 0) {
                     $messagesWithDelay[$message->getDelay()][] = $message;
                     continue;
                 }
@@ -75,8 +75,8 @@ 
                 $this->channel->batch_basic_publish($msg, $this->exchangeConfig->getName(), $message->getName());
             }
             $this->channel->publish_batch();
-            foreach($messagesWithDelay as $delay => $delayedMessages) {
-                if(!isset($this->delayedQueueWriterRegistry[$delay])) {
+            foreach ($messagesWithDelay as $delay => $delayedMessages) {
+                if (!isset($this->delayedQueueWriterRegistry[$delay])) {
                     $this->delayedQueueWriterRegistry[$delay] = new DelayedQueueWriter(
                         $this->exchangeConfig->getName(),
                         $delay,
@@ -86,8 +86,8 @@ 
                 }
                 $this->delayedQueueWriterRegistry[$delay]->write($delayedMessages);
             }
-        } catch(\Exception $exception) {
-            $this->logger->error('Error writing messages: '.$exception->getMessage());
+        } catch (\Exception $exception) {
+            $this->logger->error('Error writing messages: ' . $exception->getMessage());
             throw new WriterException($exception->getMessage(), $exception->getCode());
         }
     }
@@ -97,7 +97,7 @@ 
      */
     protected function initialize()
     {
-        if($this->channel) {
+        if ($this->channel) {
             return;
         }
         $this->logger->info('Connecting to RabbitMQ');