@@ -1,2 +1,2 @@ |
||
1 | 1 | <?php |
2 | -require_once dirname(__DIR__) . '/vendor/autoload.php'; |
|
2 | +require_once dirname(__DIR__).'/vendor/autoload.php'; |
@@ -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; |
@@ -38,11 +38,11 @@ discard block |
||
38 | 38 | return new Connection($params); |
39 | 39 | }); |
40 | 40 | |
41 | - $this->app->singleton(QueueConfig::class, function (Application $app) use ($rabbitMqConfig) { |
|
41 | + $this->app->singleton(QueueConfig::class, function(Application $app) use ($rabbitMqConfig) { |
|
42 | 42 | return new QueueConfig($rabbitMqConfig['queue'] ?? []); |
43 | 43 | }); |
44 | 44 | |
45 | - $this->app->singleton(QueueDeclarer::class, function (Application $app) use ($rabbitMqConfig) { |
|
45 | + $this->app->singleton(QueueDeclarer::class, function(Application $app) use ($rabbitMqConfig) { |
|
46 | 46 | return new QueueDeclarer($app[Connection::class], $app[QueueConfig::class]); |
47 | 47 | }); |
48 | 48 | |
@@ -54,7 +54,7 @@ discard block |
||
54 | 54 | return new Producer($app[Connection::class], $app[QueueDeclarer::class]); |
55 | 55 | }); |
56 | 56 | |
57 | - $this->app->booted(function () use ($rabbitMqConfig) { |
|
57 | + $this->app->booted(function() use ($rabbitMqConfig) { |
|
58 | 58 | $queueManager = $this->app[QueueManager::class]; |
59 | 59 | $queueManager->addConnector('rabbitmq', function() use ($rabbitMqConfig) { |
60 | 60 | return new RabbitMQConnector( |