FM / Console

/home/techb158/immovalet.com/vendor/laravel/framework/src/Illuminate/Queue/Console/

/home/techb158/immovalet.com/vendor/laravel/framework/src/Illuminate/Queue/Console

Name	Size	Mode	Actions
stubs/	-	0755	rm
BatchesTableCommand.php	2430	0644	edit dl rm
ClearCommand.php	2640	0644	edit dl rm
FailedTableCommand.php	2423	0644	edit dl rm
FlushFailedCommand.php	617	0644	edit dl rm
ForgetFailedCommand.php	770	0644	edit dl rm
ListenCommand.php	3722	0644	edit dl rm
ListFailedCommand.php	2594	0644	edit dl rm
PruneBatchesCommand.php	1482	0644	edit dl rm
PruneFailedJobsCommand.php	1128	0644	edit dl rm
RestartCommand.php	1190	0644	edit dl rm
RetryBatchCommand.php	1124	0644	edit dl rm
RetryCommand.php	4914	0644	edit dl rm
TableCommand.php	2388	0644	edit dl rm
WorkCommand.php	7686	0644	edit dl rm

Edit: /home/techb158/immovalet.com/vendor/laravel/framework/src/Illuminate/Queue/Console/ClearCommand.php (2640B)

<?php

namespace Illuminate\Queue\Console;

use Illuminate\Console\Command;
use Illuminate\Console\ConfirmableTrait;
use Illuminate\Contracts\Queue\ClearableQueue;
use ReflectionClass;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputOption;

class ClearCommand extends Command
{
    use ConfirmableTrait;

/**
     * The console command name.
     *
     * @var string
     */
    protected $name = 'queue:clear';

/**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Delete all of the jobs from the specified queue';

/**
     * Execute the console command.
     *
     * @return int|null
     */
    public function handle()
    {
        if (! $this->confirmToProceed()) {
            return 1;
        }

$connection = $this->argument('connection')
                        ?: $this->laravel['config']['queue.default'];

// We need to get the right queue for the connection which is set in the queue
        // configuration file for the application. We will pull it based on the set
        // connection being run for the queue operation currently being executed.
        $queueName = $this->getQueue($connection);

$queue = ($this->laravel['queue'])->connection($connection);

if ($queue instanceof ClearableQueue) {
            $count = $queue->clear($queueName);

$this->line('<info>Cleared '.$count.' jobs from the ['.$queueName.'] queue</info> ');
        } else {
            $this->line('<error>Clearing queues is not supported on ['.(new ReflectionClass($queue))->getShortName().']</error> ');
        }

return 0;
    }

/**
     * Get the queue name to clear.
     *
     * @param  string  $connection
     * @return string
     */
    protected function getQueue($connection)
    {
        return $this->option('queue') ?: $this->laravel['config']->get(
            "queue.connections.{$connection}.queue", 'default'
        );
    }

/**
     *  Get the console command arguments.
     *
     * @return array
     */
    protected function getArguments()
    {
        return [
            ['connection', InputArgument::OPTIONAL, 'The name of the queue connection to clear'],
        ];
    }

/**
     * Get the console command options.
     *
     * @return array
     */
    protected function getOptions()
    {
        return [
            ['queue', null, InputOption::VALUE_OPTIONAL, 'The name of the queue to clear'],

['force', null, InputOption::VALUE_NONE, 'Force the operation to run when in production'],
        ];
    }
}

confirmToProceed()) { return 1; } $connection = $this->argument('connection') ?: $this->laravel['config']['queue.default']; // We need to get the right queue for the connection which is set in the queue // configuration file for the application. We will pull it based on the set // connection being run for the queue operation currently being executed. $queueName = $this->getQueue($connection); $queue = ($this->laravel['queue'])->connection($connection); if ($queue instanceof ClearableQueue) { $count = $queue->clear($queueName); $this->line('Cleared '.$count.' jobs from the ['.$queueName.'] queue '); } else { $this->line('Clearing queues is not supported on ['.(new ReflectionClass($queue))->getShortName().'] '); } return 0; } /** * Get the queue name to clear. * * @param string $connection * @return string */ protected function getQueue($connection) { return $this->option('queue') ?: $this->laravel['config']->get( "queue.connections.{$connection}.queue", 'default' ); } /** * Get the console command arguments. * * @return array */ protected function getArguments() { return [ ['connection', InputArgument::OPTIONAL, 'The name of the queue connection to clear'], ]; } /** * Get the console command options. * * @return array */ protected function getOptions() { return [ ['queue', null, InputOption::VALUE_OPTIONAL, 'The name of the queue to clear'], ['force', null, InputOption::VALUE_NONE, 'Force the operation to run when in production'], ]; } }