We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents e5a698f + 1c27893 commit 3ca0bbbCopy full SHA for 3ca0bbb
src/LaravelQueueRabbitMQServiceProvider.php
@@ -4,6 +4,7 @@
4
5
use Illuminate\Queue\QueueManager;
6
use Illuminate\Support\ServiceProvider;
7
+use PhpAmqpLib\Connection\AMQPStreamConnection;
8
use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnector;
9
use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnectorSSL;
10
@@ -38,11 +39,14 @@ public function boot()
38
39
}
40
41
$queue->stopping(function () use ($connector) {
- $connector->connection()->close();
42
+ if ($connector->connection() instanceof AMQPStreamConnection) {
43
+ $connector->connection()->close();
44
+ }
45
});
46
47
$queue->addConnector('rabbitmq', function () use ($connector) {
48
return $connector;
49
50
51
52
+
0 commit comments