--- /dev/null
+<?php
+
+/**
+ * @file
+ * Contains \Drupal\Console\Command\Debug\QueueCommand.
+ */
+
+namespace Drupal\Console\Command\Debug;
+
+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;
+
+/**
+ * Class DebugCommand
+ *
+ * @package Drupal\Console\Command\Debug
+ */
+class QueueCommand extends Command
+{
+ /**
+ * @var QueueFactory
+ */
+ protected $queueFactory;
+
+ /**
+ * @var QueueWorkerManagerInterface
+ */
+ protected $queueWorker;
+
+ /**
+ * DebugCommand constructor.
+ *
+ * @param QueueWorkerManagerInterface $queueWorker
+ */
+ public function __construct(QueueFactory $queueFactory, QueueWorkerManagerInterface $queueWorker)
+ {
+ $this->queueFactory = $queueFactory;
+ $this->queueWorker = $queueWorker;
+ parent::__construct();
+ }
+
+ /**
+ * {@inheritdoc}
+ */
+ protected function configure()
+ {
+ $this
+ ->setName('debug:queue')
+ ->setDescription($this->trans('commands.debug.queue.description'))
+ ->setAliases(['dq']);
+ }
+
+ /**
+ * {@inheritdoc}
+ */
+ protected function execute(InputInterface $input, OutputInterface $output)
+ {
+ $tableHeader = [
+ $this->trans('commands.debug.queue.messages.queue'),
+ $this->trans('commands.debug.queue.messages.items'),
+ $this->trans('commands.debug.queue.messages.class')
+ ];
+
+ $tableBody = $this->listQueues();
+
+ $this->getIo()->table($tableHeader, $tableBody);
+
+ return 0;
+ }
+
+ /**
+ * listQueues.
+ */
+ private function listQueues()
+ {
+ $queues = [];
+ foreach ($this->queueWorker->getDefinitions() as $name => $info) {
+ $queues[$name] = $this->formatQueue($name);
+ }
+
+ return $queues;
+ }
+
+ /**
+ * @param $name
+ * @return array
+ */
+ private function formatQueue($name)
+ {
+ $q = $this->queueFactory->get($name);
+
+ return [
+ $name,
+ $q->numberOfItems(),
+ get_class($q)
+ ];
+ }
+}