public function flushCommand($queue, $force = false)
    {
        $queue = $this->queueManager->getQueue($queue);
        if (!$force) {
            $this->outputLine('Use the --force flag if you really want to flush queue "%s"', [$queue->getName()]);
            $this->outputLine('<error>Warning: This will delete all messages from the queue!</error>');
            $this->quit(1);
        }
        $queue->flush();
        $this->outputLine('<success>Flushed queue "%s".</success>', [$queue->getName()]);
    }