@@ -20,7 +20,7 @@ |
||
| 20 | 20 | { |
| 21 | 21 | $self = $this; |
| 22 | 22 | |
| 23 | - $pimple->offsetSet(static::CONTAINER_KEY_CONFIG, static function (Container $container) use ($self) { |
|
| 23 | + $pimple->offsetSet(static::CONTAINER_KEY_CONFIG, static function(Container $container) use ($self) { |
|
| 24 | 24 | return $self->createConfig($container); |
| 25 | 25 | }); |
| 26 | 26 | } |
@@ -40,7 +40,7 @@ discard block |
||
| 40 | 40 | |
| 41 | 41 | $container->offsetSet( |
| 42 | 42 | static::CONTAINER_KEY_CONNECTION, |
| 43 | - static function (Container $container) use ($self) { |
|
| 43 | + static function(Container $container) use ($self) { |
|
| 44 | 44 | $lazyConnection = $self->createAmqpLazyConnection($container); |
| 45 | 45 | |
| 46 | 46 | return new Connection($lazyConnection); |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | */ |
| 58 | 58 | protected function registerAmqpMessageFactory(Container $container): QueueRabbitMqServiceProvider |
| 59 | 59 | { |
| 60 | - $container->offsetSet(static::CONTAINER_KEY_AMQP_MESSAGE_FACTORY, static function () { |
|
| 60 | + $container->offsetSet(static::CONTAINER_KEY_AMQP_MESSAGE_FACTORY, static function() { |
|
| 61 | 61 | return new AmqpMessageFactory(); |
| 62 | 62 | }); |
| 63 | 63 | |
@@ -75,7 +75,7 @@ discard block |
||
| 75 | 75 | |
| 76 | 76 | $container->offsetSet( |
| 77 | 77 | QueueServiceProvider::CONTAINER_KEY_QUEUE_CLIENT, |
| 78 | - static function (Container $container) use ($self) { |
|
| 78 | + static function(Container $container) use ($self) { |
|
| 79 | 79 | return new QueueClient( |
| 80 | 80 | $self->createConsumers($container), |
| 81 | 81 | $self->createProducers($container) |
@@ -33,7 +33,7 @@ discard block |
||
| 33 | 33 | */ |
| 34 | 34 | protected function registerMessageFactory(Container $container): QueueServiceProvider |
| 35 | 35 | { |
| 36 | - $container->offsetSet(static::CONTAINER_KEY_MESSAGE_FACTORY, static function () { |
|
| 36 | + $container->offsetSet(static::CONTAINER_KEY_MESSAGE_FACTORY, static function() { |
|
| 37 | 37 | return new MessageFactory(); |
| 38 | 38 | }); |
| 39 | 39 | |
@@ -47,7 +47,7 @@ discard block |
||
| 47 | 47 | */ |
| 48 | 48 | protected function registerMessageMapper(Container $container): QueueServiceProvider |
| 49 | 49 | { |
| 50 | - $container->offsetSet(static::CONTAINER_KEY_MESSAGE_MAPPER, static function (Container $container) { |
|
| 50 | + $container->offsetSet(static::CONTAINER_KEY_MESSAGE_MAPPER, static function(Container $container) { |
|
| 51 | 51 | return new MessageMapper( |
| 52 | 52 | $container->offsetGet('serializer') |
| 53 | 53 | ); |
@@ -58,7 +58,7 @@ discard block |
||
| 58 | 58 | |
| 59 | 59 | protected function registerDestinationFactory(Container $container): QueueServiceProvider |
| 60 | 60 | { |
| 61 | - $container->offsetSet(static::CONTAINER_KEY_DESTINATION_FACTORY, static function () { |
|
| 61 | + $container->offsetSet(static::CONTAINER_KEY_DESTINATION_FACTORY, static function() { |
|
| 62 | 62 | return new DestinationFactory(); |
| 63 | 63 | }); |
| 64 | 64 | |