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