@@ -3,7 +3,6 @@ |
||
3 | 3 | namespace Ccovey\LaravelRabbitMQ; |
4 | 4 | |
5 | 5 | use Ccovey\RabbitMQ\Producer\Message; |
6 | -use Ccovey\RabbitMQ\Producer\Producer; |
|
7 | 6 | use Ccovey\RabbitMQ\Producer\ProducerInterface; |
8 | 7 | use Ccovey\RabbitMQ\QueuedMessage; |
9 | 8 | use DateTime; |
@@ -5,7 +5,6 @@ |
||
5 | 5 | use Ccovey\RabbitMQ\Connection\Connection; |
6 | 6 | use Ccovey\RabbitMQ\Connection\ConnectionParameters; |
7 | 7 | use Ccovey\RabbitMQ\Consumer\Consumer; |
8 | -use Ccovey\RabbitMQ\ExchangeDeclarer; |
|
9 | 8 | use Ccovey\RabbitMQ\Producer\Producer; |
10 | 9 | use Ccovey\RabbitMQ\QueueDeclarer; |
11 | 10 | use Illuminate\Contracts\Foundation\Application; |
@@ -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( |