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.
1 parent e5a698f commit 1c27893Copy full SHA for 1c27893
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