@@ -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 |