@@ -61,7 +61,7 @@ discard block |
||
61 | 61 | */ |
62 | 62 | private function createExchangeCollection(DependencyContainerInterface $container): DependencyContainerInterface |
63 | 63 | { |
64 | - $container[self::RABBITMQ_EXCHANGES] = function (DependencyContainerInterface $container) { |
|
64 | + $container[self::RABBITMQ_EXCHANGES] = function(DependencyContainerInterface $container) { |
|
65 | 65 | return new ExchangeCollection( |
66 | 66 | $this->getExchanges() |
67 | 67 | ); |
@@ -77,7 +77,7 @@ discard block |
||
77 | 77 | */ |
78 | 78 | private function createQueueCollection(DependencyContainerInterface $container): DependencyContainerInterface |
79 | 79 | { |
80 | - $container[self::RABBITMQ_QUEUES] = function (DependencyContainerInterface $container) { |
|
80 | + $container[self::RABBITMQ_QUEUES] = function(DependencyContainerInterface $container) { |
|
81 | 81 | return new QueueCollection( |
82 | 82 | $this->getQueues() |
83 | 83 | ); |
@@ -93,7 +93,7 @@ discard block |
||
93 | 93 | */ |
94 | 94 | private function createListenerCollection(DependencyContainerInterface $container): DependencyContainerInterface |
95 | 95 | { |
96 | - $container[self::RABBITMQ_LISTENER] = function (DependencyContainerInterface $container) { |
|
96 | + $container[self::RABBITMQ_LISTENER] = function(DependencyContainerInterface $container) { |
|
97 | 97 | return new ListenerCollection( |
98 | 98 | $this->getListener() |
99 | 99 | ); |
@@ -60,7 +60,7 @@ |
||
60 | 60 | private function createMessage(RabbitMqMessageDataProvider $messageDataDataProvider): AMQPMessage |
61 | 61 | { |
62 | 62 | return new AMQPMessage( |
63 | - (string)json_encode( |
|
63 | + (string) json_encode( |
|
64 | 64 | $messageDataDataProvider->toArray() |
65 | 65 | ), |
66 | 66 | $messageDataDataProvider->getProperties() |