|
@@ -38,11 +38,11 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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( |
Please login to merge, or discard this patch.
ccovey /
laravel-rabbitmq
