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