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()]);
    }
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()]);
    }
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 ( ) ] ) ; }
Remove all messages from a queue!

This command will delete <u>all</u> messages from the given queue.
Thus it should only be used in tests or with great care!

@param string $queue Name of the queue to flush (e.g. "some-queue")
@param bool $force This flag is required in order to avoid accidental flushes
@return void
@throws Exception
@throws StopActionException
Remove all messages from a queue!