diff --git a/config/services/debug.yml b/config/services/debug.yml index 2a3c868aa..e1407602e 100644 --- a/config/services/debug.yml +++ b/config/services/debug.yml @@ -57,7 +57,7 @@ services: - { name: drupal.command } console.queue_debug: class: Drupal\Console\Command\Debug\QueueCommand - arguments: ['@plugin.manager.queue_worker'] + arguments: ['@queue', '@plugin.manager.queue_worker'] tags: - { name: drupal.command } console.libraries_debug: diff --git a/src/Command/Debug/QueueCommand.php b/src/Command/Debug/QueueCommand.php index 066864942..023af38c3 100644 --- a/src/Command/Debug/QueueCommand.php +++ b/src/Command/Debug/QueueCommand.php @@ -10,6 +10,7 @@ use Drupal\Console\Core\Command\Command; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Output\OutputInterface; +use Drupal\Core\Queue\QueueFactory; use Drupal\Core\Queue\QueueWorkerManagerInterface; /** @@ -19,6 +20,11 @@ */ class QueueCommand extends Command { + /** + * @var QueueFactory + */ + protected $queueFactory; + /** * @var QueueWorkerManagerInterface */ @@ -29,8 +35,9 @@ class QueueCommand extends Command * * @param QueueWorkerManagerInterface $queueWorker */ - public function __construct(QueueWorkerManagerInterface $queueWorker) + public function __construct(QueueFactory $queueFactory, QueueWorkerManagerInterface $queueWorker) { + $this->queueFactory = $queueFactory; $this->queueWorker = $queueWorker; parent::__construct(); } @@ -83,7 +90,7 @@ private function listQueues() */ private function formatQueue($name) { - $q = $this->getDrupalService('queue')->get($name); + $q = $this->queueFactory->get($name); return [ $name,