thomasvargiu / laminas-messenger

src/Factory/Listener/StopWorkerOnRestartSignalListenerFactory.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 
         $cachePoolForRestartSignal = $config['messenger']['cache_pool_for_restart_signal'] ?? null;
 
-        if (! $cachePoolForRestartSignal) {
+        if (!$cachePoolForRestartSignal) {
             throw new InvalidArgumentException('Invalid cache_pool_for_restart_signal service');
         }
 

src/Factory/Transport/TransportProviderFactory.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
         $transportNames = array_keys($config['messenger']['transports'] ?? []);
 
         foreach ($transportNames as $name) {
-            $factories[(string) $name] = static function () use ($name, $container): TransportInterface {
+            $factories[(string) $name] = static function() use ($name, $container): TransportInterface {
                 /** @var TransportInterface $transport */
                 $transport = $container->get((string) $name);
 

src/Factory/Transport/TransportFactory.php

Spacing +1 added lines, -1 removed lines

@@ -68,7 +68,7 @@
      */
     public static function __callStatic(string $name, array $arguments): TransportInterface
     {
-        if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) {
+        if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) {
             throw new InvalidArgumentException(sprintf(
                 'The first argument must be of type %s',
                 ContainerInterface::class

src/Factory/Transport/Sender/SendersLocatorFactory.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
         $routing = $config['messenger']['buses'][$this->busName]['routes'] ?? [];
 
         foreach ($routing as $message => $_) {
-            if ('*' !== $message && ! class_exists((string) $message) && ! interface_exists((string) $message, false)) {
+            if ('*' !== $message && !class_exists((string) $message) && !interface_exists((string) $message, false)) {
                 throw new LogicException(sprintf('Invalid Messenger routing configuration: class or interface "%s" not found.', $message));
             }
         }

src/Factory/RoutableMessageBusFactory.php

Spacing +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
      */
     public static function __callStatic(string $name, array $arguments): MessageBusInterface
     {
-        if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) {
+        if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) {
             throw new InvalidArgumentException(sprintf(
                 'The first argument must be of type %s',
                 ContainerInterface::class

src/Factory/Command/FailedMessagesRemoveCommandFactory.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
         return new FailedMessagesRemoveCommand(
             $failureTransportName,
             new ServiceProvider([
-                $failureTransportName => static function () use ($receiverLocator, $failureTransportName) { return $receiverLocator->get($failureTransportName); },
+                $failureTransportName => static function() use ($receiverLocator, $failureTransportName) { return $receiverLocator->get($failureTransportName); },
             ]),
         );
     }

src/Factory/Command/FailedMessagesShowCommandFactory.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
         return new FailedMessagesShowCommand(
             $failureTransportName,
             new ServiceProvider([
-                $failureTransportName => static function () use ($receiverLocator, $failureTransportName) { return $receiverLocator->get($failureTransportName); },
+                $failureTransportName => static function() use ($receiverLocator, $failureTransportName) { return $receiverLocator->get($failureTransportName); },
             ]),
         );
     }

src/Factory/Command/FailedMessagesRetryCommandFactory.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
         return new FailedMessagesRetryCommand(
             $failureTransportName,
             new ServiceProvider([
-                $failureTransportName => static function () use ($receiverLocator, $failureTransportName) { return $receiverLocator->get($failureTransportName); },
+                $failureTransportName => static function() use ($receiverLocator, $failureTransportName) { return $receiverLocator->get($failureTransportName); },
             ]),
             $messageBus,
             $container->get($eventDispatcher),

src/Factory/Retry/RetryStrategyLocatorFactory.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
         $factories = [];
 
         foreach ($transports as $name => $_) {
-            $factories[$name] = static function () use ($name, $container): RetryStrategyInterface {
+            $factories[$name] = static function() use ($name, $container): RetryStrategyInterface {
                 return (new RetryStrategyFactory($name))($container);
             };
         }