diff --git a/src/EnqueueServiceProvider.php b/src/EnqueueServiceProvider.php index 999c8c1..5bf5687 100644 --- a/src/EnqueueServiceProvider.php +++ b/src/EnqueueServiceProvider.php @@ -60,7 +60,7 @@ private function bootInteropQueueDriver() }); $manager->addConnector('amqp_interop', function () { - return new AmqpConnector(); + return new Connector(); }); $this->app->extend('queue.worker', function ($worker, $app) {