FlushFailed.php 442 B

123456789101112131415161718192021
  1. <?php
  2. namespace think\queue\command;
  3. use think\console\Command;
  4. class FlushFailed extends Command
  5. {
  6. protected function configure()
  7. {
  8. $this->setName('queue:flush')
  9. ->setDescription('Flush all of the failed queue jobs');
  10. }
  11. public function handle()
  12. {
  13. $this->app->get('queue.failer')->flush();
  14. $this->output->info('All failed jobs deleted successfully!');
  15. }
  16. }