diff --git a/composer.json b/composer.json index 20ddeb9..68c7778 100644 --- a/composer.json +++ b/composer.json @@ -6,7 +6,7 @@ "license": "MIT", "require": { "php": ">=7.1", - "illuminate/queue": "^5.6", + "illuminate/queue": "^6.0", "queue-interop/amqp-interop": "^0.8", "queue-interop/queue-interop": "^0.7|^0.8", "enqueue/enqueue": "^0.9", diff --git a/src/EnqueueServiceProvider.php b/src/EnqueueServiceProvider.php index 5bf5687..36ac9d8 100644 --- a/src/EnqueueServiceProvider.php +++ b/src/EnqueueServiceProvider.php @@ -65,7 +65,12 @@ private function bootInteropQueueDriver() $this->app->extend('queue.worker', function ($worker, $app) { return new Worker( - $app['queue'], $app['events'], $app[ExceptionHandler::class] + $app['queue'], + $app['events'], + $app[ExceptionHandler::class], + function () use ($app) { + return $app->isDownForMaintenance(); + } ); }); }