Werkspot / message-queue

src/DeliveryQueue/MessageHandler.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Werkspot\MessageQueue\DeliveryQueue;
 

src/DeliveryQueue/Amqp/AmqpConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Werkspot\MessageQueue\DeliveryQueue\Amqp;
 

src/DeliveryQueue/Amqp/AmqpMessageHandler.php

Spacing +1 added lines, -1 removed lines

@@ -184,7 +184,7 @@
             throw new AmqpMessageUnpackingException(self::UNPACKING_EXCEPTION_MSG_UNSERIALIZABLE_CONTENT);
         }
 
-        if (! $result instanceof MessageInterface) {
+        if (!$result instanceof MessageInterface) {
             throw new AmqpMessageUnpackingException(self::UNPACKING_EXCEPTION_MSG_UNEXPECTED_TYPE);
         }
 

src/ScheduledQueueToDeliveryQueueWorker.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
 
     public function moveMessageBatch(int $batchSize, callable $afterMessageTransfer = null): int
     {
-        $afterMessageTransfer = $afterMessageTransfer ?? function () {
+        $afterMessageTransfer = $afterMessageTransfer ?? function() {
         };
         $messageList = $this->scheduledMessageService->findScheduledMessageList($batchSize);