From 52f4fea38481920434802e8d56524f948e9cac3f Mon Sep 17 00:00:00 2001 From: Arif Hoque Date: Thu, 29 Jan 2026 13:41:50 +0600 Subject: [PATCH] console command handle() method dependency injection: --- src/Commands/MakeJobCommand.php | 2 +- src/Commands/QueueFailedCommand.php | 3 +-- src/Commands/QueueFlushCommand.php | 3 +-- src/Commands/QueueMonitorCommand.php | 2 +- src/Commands/QueueRetryCommand.php | 2 +- src/Commands/QueueRunCommand.php | 2 +- 6 files changed, 6 insertions(+), 8 deletions(-) diff --git a/src/Commands/MakeJobCommand.php b/src/Commands/MakeJobCommand.php index 34ee152..0dbc6bf 100644 --- a/src/Commands/MakeJobCommand.php +++ b/src/Commands/MakeJobCommand.php @@ -25,7 +25,7 @@ class MakeJobCommand extends Command * * @return int */ - protected function handle(): int + public function handle(): int { return $this->executeWithTiming(function () { $name = $this->argument('name'); diff --git a/src/Commands/QueueFailedCommand.php b/src/Commands/QueueFailedCommand.php index bc3e9b0..68d65f0 100644 --- a/src/Commands/QueueFailedCommand.php +++ b/src/Commands/QueueFailedCommand.php @@ -3,7 +3,6 @@ namespace Doppar\Queue\Commands; use Phaseolies\Console\Schedule\Command; -use Doppar\Queue\QueueManager; use Doppar\Queue\Models\FailedJob; class QueueFailedCommand extends Command @@ -28,7 +27,7 @@ class QueueFailedCommand extends Command * * @return int */ - protected function handle(): int + public function handle(): int { $failedJobs = FailedJob::orderBy('failed_at', 'desc')->get(); diff --git a/src/Commands/QueueFlushCommand.php b/src/Commands/QueueFlushCommand.php index 6d3e058..b5b5736 100644 --- a/src/Commands/QueueFlushCommand.php +++ b/src/Commands/QueueFlushCommand.php @@ -3,7 +3,6 @@ namespace Doppar\Queue\Commands; use Phaseolies\Console\Schedule\Command; -use Doppar\Queue\QueueManager; use Doppar\Queue\Models\FailedJob; class QueueFlushCommand extends Command @@ -28,7 +27,7 @@ class QueueFlushCommand extends Command * * @return int */ - protected function handle(): int + public function handle(): int { $id = $this->option('id'); diff --git a/src/Commands/QueueMonitorCommand.php b/src/Commands/QueueMonitorCommand.php index 0417fa3..e6064aa 100644 --- a/src/Commands/QueueMonitorCommand.php +++ b/src/Commands/QueueMonitorCommand.php @@ -27,7 +27,7 @@ class QueueMonitorCommand extends Command * * @return int */ - protected function handle(): int + public function handle(): int { $queues = QueueJob::groupBy('queue')->pluck('queue'); diff --git a/src/Commands/QueueRetryCommand.php b/src/Commands/QueueRetryCommand.php index af8f80a..3c18e45 100644 --- a/src/Commands/QueueRetryCommand.php +++ b/src/Commands/QueueRetryCommand.php @@ -28,7 +28,7 @@ class QueueRetryCommand extends Command * * @return int */ - protected function handle(): int + public function handle(): int { $id = $this->option('id'); $manager = app(QueueManager::class); diff --git a/src/Commands/QueueRunCommand.php b/src/Commands/QueueRunCommand.php index 0e7af03..4d4dbff 100644 --- a/src/Commands/QueueRunCommand.php +++ b/src/Commands/QueueRunCommand.php @@ -54,7 +54,7 @@ public function __construct(QueueManager $manager) * * @return int */ - protected function handle(): int + public function handle(): int { return $this->withTiming(function () { $queue = $this->option('queue', 'default');