@@ -37,7 +37,7 @@ discard block |
||
37 | 37 | return new Connection($params); |
38 | 38 | }); |
39 | 39 | |
40 | - $this->app->singleton(QueueDeclarer::class, function (Application $app) use ($rabbitMqConfig) { |
|
40 | + $this->app->singleton(QueueDeclarer::class, function(Application $app) use ($rabbitMqConfig) { |
|
41 | 41 | return new QueueDeclarer($app[Connection::class], $rabbitMqConfig['queue'] ?? []); |
42 | 42 | }); |
43 | 43 | |
@@ -49,7 +49,7 @@ discard block |
||
49 | 49 | return new Producer($app[Connection::class], $app[QueueDeclarer::class]); |
50 | 50 | }); |
51 | 51 | |
52 | - $this->app->booted(function () use ($rabbitMqConfig) { |
|
52 | + $this->app->booted(function() use ($rabbitMqConfig) { |
|
53 | 53 | $queueManager = $this->app[QueueManager::class]; |
54 | 54 | $queueManager->addConnector('rabbitmq', function() use ($rabbitMqConfig) { |
55 | 55 | return new RabbitMQConnector( |