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