@@ -27,12 +27,12 @@ |
||
| 27 | 27 | { |
| 28 | 28 | $connection = $entityManager->getConnection(); |
| 29 | 29 | |
| 30 | - if (! $connection->ping()) { |
|
| 30 | + if ( ! $connection->ping()) { |
|
| 31 | 31 | $connection->close(); |
| 32 | 32 | $connection->connect(); |
| 33 | 33 | } |
| 34 | 34 | |
| 35 | - if (! $entityManager->isOpen()) { |
|
| 35 | + if ( ! $entityManager->isOpen()) { |
|
| 36 | 36 | $this->managerRegistry->resetManager($this->entityManagerName); |
| 37 | 37 | } |
| 38 | 38 | } |
@@ -17,7 +17,7 @@ |
||
| 17 | 17 | $factories = []; |
| 18 | 18 | |
| 19 | 19 | foreach ($transports as $name => $transport) { |
| 20 | - $factories[$name] = static function () use ($name, $container): RetryStrategyInterface { |
|
| 20 | + $factories[$name] = static function() use ($name, $container): RetryStrategyInterface { |
|
| 21 | 21 | return (new RetryStrategyFactory($name))($container); |
| 22 | 22 | }; |
| 23 | 23 | } |
@@ -20,7 +20,7 @@ discard block |
||
| 20 | 20 | $receivers = $config['messenger']['receivers'] ?? []; |
| 21 | 21 | |
| 22 | 22 | foreach ($transportNames as $name) { |
| 23 | - $factories[(string) $name] = static function () use ($name, $container): ReceiverInterface { |
|
| 23 | + $factories[(string) $name] = static function() use ($name, $container): ReceiverInterface { |
|
| 24 | 24 | return $container->get((string) $name); |
| 25 | 25 | }; |
| 26 | 26 | } |
@@ -30,7 +30,7 @@ discard block |
||
| 30 | 30 | throw new InvalidArgumentException(sprintf('A receiver named "%s" already exists as a transport name', $name)); |
| 31 | 31 | } |
| 32 | 32 | |
| 33 | - $factories[(string) $name] = static function () use ($serviceName, $container): ReceiverInterface { |
|
| 33 | + $factories[(string) $name] = static function() use ($serviceName, $container): ReceiverInterface { |
|
| 34 | 34 | return $container->get($serviceName); |
| 35 | 35 | }; |
| 36 | 36 | } |
@@ -33,7 +33,7 @@ |
||
| 33 | 33 | */ |
| 34 | 34 | public static function __callStatic(string $name, array $arguments): AddBusNameStampMiddleware |
| 35 | 35 | { |
| 36 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 36 | + if ( ! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 37 | 37 | throw new InvalidArgumentException(sprintf( |
| 38 | 38 | 'The first argument must be of type %s', |
| 39 | 39 | ContainerInterface::class |
@@ -51,7 +51,7 @@ |
||
| 51 | 51 | */ |
| 52 | 52 | public static function __callStatic(string $name, array $arguments): SendMessageMiddleware |
| 53 | 53 | { |
| 54 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 54 | + if ( ! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 55 | 55 | throw new InvalidArgumentException(sprintf( |
| 56 | 56 | 'The first argument must be of type %s', |
| 57 | 57 | ContainerInterface::class |
@@ -47,7 +47,7 @@ |
||
| 47 | 47 | */ |
| 48 | 48 | public static function __callStatic(string $name, array $arguments): HandleMessageMiddleware |
| 49 | 49 | { |
| 50 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 50 | + if ( ! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 51 | 51 | throw new InvalidArgumentException(sprintf( |
| 52 | 52 | 'The first argument must be of type %s', |
| 53 | 53 | ContainerInterface::class |
@@ -30,7 +30,7 @@ |
||
| 30 | 30 | */ |
| 31 | 31 | public static function __callStatic(string $name, array $arguments): MiddlewareInterface |
| 32 | 32 | { |
| 33 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 33 | + if ( ! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 34 | 34 | throw new InvalidArgumentException(sprintf( |
| 35 | 35 | 'The first argument must be of type %s', |
| 36 | 36 | ContainerInterface::class |
@@ -68,7 +68,7 @@ |
||
| 68 | 68 | */ |
| 69 | 69 | public static function __callStatic(string $name, array $arguments): MessageBusInterface |
| 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 |
@@ -65,7 +65,7 @@ |
||
| 65 | 65 | */ |
| 66 | 66 | public static function __callStatic(string $name, array $arguments): TransportInterface |
| 67 | 67 | { |
| 68 | - if (! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 68 | + if ( ! array_key_exists(0, $arguments) || ! $arguments[0] instanceof ContainerInterface) { |
|
| 69 | 69 | throw new InvalidArgumentException(sprintf( |
| 70 | 70 | 'The first argument must be of type %s', |
| 71 | 71 | ContainerInterface::class |