*/ protected $aliases = ['queue:continue']; /** * The console command description. * * @var string */ protected $description = 'Resume job processing for a paused queue'; /** * Execute the console command. * * @return int */ public function handle(QueueManager $manager): int { if ($this->option('all')) { $manager->resumeAll(); $this->components->info('Job processing on all queues across all connections has been resumed.'); return self::SUCCESS; } if (! $this->argument('queue')) { $this->components->error('A queue name is required unless the --all option is used.'); return self::FAILURE; } [$connection, $queue] = $this->parseQueue($this->argument('queue')); $manager->resume($connection, $queue); $this->components->info("Job processing on queue [{$connection}:{$queue}] has been resumed."); return self::SUCCESS; } }