@@ -23,7 +23,7 @@ |
||
| 23 | 23 | |
| 24 | 24 | $cachePoolForRestartSignal = $config['messenger']['cache_pool_for_restart_signal'] ?? null; |
| 25 | 25 | |
| 26 | - if (! $cachePoolForRestartSignal) { |
|
| 26 | + if (!$cachePoolForRestartSignal) { |
|
| 27 | 27 | throw new InvalidArgumentException('Invalid cache_pool_for_restart_signal service'); |
| 28 | 28 | } |
| 29 | 29 | |
@@ -21,7 +21,7 @@ |
||
| 21 | 21 | $transportNames = array_keys($config['messenger']['transports'] ?? []); |
| 22 | 22 | |
| 23 | 23 | foreach ($transportNames as $name) { |
| 24 | - $factories[(string) $name] = static function () use ($name, $container): TransportInterface { |
|
| 24 | + $factories[(string) $name] = static function() use ($name, $container): TransportInterface { |
|
| 25 | 25 | /** @var TransportInterface $transport */ |
| 26 | 26 | $transport = $container->get((string) $name); |
| 27 | 27 | |
@@ -27,7 +27,7 @@ discard block |
||
| 27 | 27 | $receivers = $config['messenger']['receivers'] ?? []; |
| 28 | 28 | |
| 29 | 29 | foreach ($transportNames as $name) { |
| 30 | - $factories[(string) $name] = static function () use ($name, $container): ReceiverInterface { |
|
| 30 | + $factories[(string) $name] = static function() use ($name, $container): ReceiverInterface { |
|
| 31 | 31 | return $container->get((string) $name); |
| 32 | 32 | }; |
| 33 | 33 | } |
@@ -37,7 +37,7 @@ discard block |
||
| 37 | 37 | throw new InvalidArgumentException(sprintf('A receiver named "%s" already exists as a transport name', $name)); |
| 38 | 38 | } |
| 39 | 39 | |
| 40 | - $factories[(string) $name] = static function () use ($serviceName, $container): ReceiverInterface { |
|
| 40 | + $factories[(string) $name] = static function() use ($serviceName, $container): ReceiverInterface { |
|
| 41 | 41 | return $container->get($serviceName); |
| 42 | 42 | }; |
| 43 | 43 | } |
@@ -68,7 +68,7 @@ |
||
| 68 | 68 | */ |
| 69 | 69 | public static function __callStatic(string $name, array $arguments): TransportInterface |
| 70 | 70 | { |
| 71 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 71 | + if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) { |
|
| 72 | 72 | throw new InvalidArgumentException(sprintf( |
| 73 | 73 | 'The first argument must be of type %s', |
| 74 | 74 | ContainerInterface::class |
@@ -34,7 +34,7 @@ |
||
| 34 | 34 | $routing = $config['messenger']['buses'][$this->busName]['routes'] ?? []; |
| 35 | 35 | |
| 36 | 36 | foreach ($routing as $message => $_) { |
| 37 | - if ('*' !== $message && ! class_exists((string) $message) && ! interface_exists((string) $message, false)) { |
|
| 37 | + if ('*' !== $message && !class_exists((string) $message) && !interface_exists((string) $message, false)) { |
|
| 38 | 38 | throw new LogicException(sprintf('Invalid Messenger routing configuration: class or interface "%s" not found.', $message)); |
| 39 | 39 | } |
| 40 | 40 | } |
@@ -40,7 +40,7 @@ |
||
| 40 | 40 | */ |
| 41 | 41 | public static function __callStatic(string $name, array $arguments): MessageBusInterface |
| 42 | 42 | { |
| 43 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 43 | + if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) { |
|
| 44 | 44 | throw new InvalidArgumentException(sprintf( |
| 45 | 45 | 'The first argument must be of type %s', |
| 46 | 46 | ContainerInterface::class |
@@ -50,7 +50,7 @@ |
||
| 50 | 50 | */ |
| 51 | 51 | public static function __callStatic(string $name, array $arguments): HandleMessageMiddleware |
| 52 | 52 | { |
| 53 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 53 | + if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) { |
|
| 54 | 54 | throw new InvalidArgumentException(sprintf( |
| 55 | 55 | 'The first argument must be of type %s', |
| 56 | 56 | ContainerInterface::class |
@@ -54,7 +54,7 @@ |
||
| 54 | 54 | */ |
| 55 | 55 | public static function __callStatic(string $name, array $arguments): SendMessageMiddleware |
| 56 | 56 | { |
| 57 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 57 | + if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) { |
|
| 58 | 58 | throw new InvalidArgumentException(sprintf( |
| 59 | 59 | 'The first argument must be of type %s', |
| 60 | 60 | ContainerInterface::class |
@@ -29,7 +29,7 @@ |
||
| 29 | 29 | */ |
| 30 | 30 | public static function __callStatic(string $name, array $arguments): MiddlewareInterface |
| 31 | 31 | { |
| 32 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 32 | + if (!array_key_exists(0, $arguments) || !$arguments[0] instanceof ContainerInterface) { |
|
| 33 | 33 | throw new InvalidArgumentException(sprintf( |
| 34 | 34 | 'The first argument must be of type %s', |
| 35 | 35 | ContainerInterface::class |