antidot-framework / message-queue

src/Cli/StartQueueConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
         $container = $this->actionContainer;
         $this->consumer->bindCallback(
             $queue,
-            static function (Message $message) use ($container) {
+            static function(Message $message) use ($container) {
                 try {
                     $jobPayload = JobPayload::createFromMessage($message);
                     $action = $container->get($jobPayload->type());

src/Container/StartQueueConsumerFactory.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
     ): StartQueueConsumer {
         return new StartQueueConsumer(
             $container->get(QueueConsumerInterface::class),
-            $container->get($contextName . '.action.container')
+            $container->get($contextName.'.action.container')
         );
     }
 }

src/Container/Config/ConfigProvider.php

Spacing +3 added lines, -3 removed lines

@@ -37,9 +37,9 @@
             ],
         ],
         'factories' => [
-            self::DEFAULT_CONTEXT . '.action.container' => ActionContainerFactory::class,
-            self::DEFAULT_CONTEXT . '.message.processor' => MessageProcessorFactory::class,
-            self::DEFAULT_CONTEXT . '.message.producer' => ProducerFactory::class,
+            self::DEFAULT_CONTEXT.'.action.container' => ActionContainerFactory::class,
+            self::DEFAULT_CONTEXT.'.message.processor' => MessageProcessorFactory::class,
+            self::DEFAULT_CONTEXT.'.message.producer' => ProducerFactory::class,
             MessageProcessor::class => MessageProcessorFactory::class,
             Producer::class => ProducerFactory::class,
         ],