|
@@ -43,7 +43,7 @@ |
|
|
block discarded – undo |
|
43
|
43
|
return new Producer($app[Connection::class]); |
|
44
|
44
|
}); |
|
45
|
45
|
|
|
46
|
|
- $this->app->booted(function () use ($rabbitMqConfig) { |
|
|
46
|
+ $this->app->booted(function() use ($rabbitMqConfig) { |
|
47
|
47
|
$queueManager = $this->app[QueueManager::class]; |
|
48
|
48
|
$queueManager->addConnector('rabbitmq', function() use ($rabbitMqConfig) { |
|
49
|
49
|
return new RabbitMQConnector($this->app[Consumer::class], $this->app[Producer::class], $rabbitMqConfig); |
Please login to merge, or discard this patch.