|
@@ -37,7 +37,7 @@ discard block |
|
|
block discarded – undo |
|
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 |
|
|
block discarded – undo |
|
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( |
Please login to merge, or discard this patch.