Fix the job repository class based on service bindings (#1335)

* Fix the job repository class based on service bindings * fix --------- Co-authored-by: Taylor Otwell <[email protected]>
laravel · Oct 11, 2023 · 1ac9ffd · 1ac9ffd
1 parent 56552ff
commit 1ac9ffd
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/Console/ClearCommand.php b/src/Console/ClearCommand.php
@@ -6,6 +6,7 @@
 use Illuminate\Console\ConfirmableTrait;
 use Illuminate\Queue\QueueManager;
 use Illuminate\Support\Arr;
+use Laravel\Horizon\Contracts\JobRepository;
 use Laravel\Horizon\RedisQueue;
 use Laravel\Horizon\Repositories\RedisJobRepository;
 
@@ -34,7 +35,7 @@ class ClearCommand extends Command
      *
      * @return int|null
      */
-    public function handle(RedisJobRepository $jobRepository, QueueManager $manager)
+    public function handle(JobRepository $jobRepository, QueueManager $manager)
     {
         if (! $this->confirmToProceed()) {
             return 1;
@@ -48,7 +49,9 @@ public function handle(RedisJobRepository $jobRepository, QueueManager $manager)
 
         $connection = Arr::first($this->laravel['config']->get('horizon.defaults'))['connection'] ?? 'redis';
 
-        $jobRepository->purge($queue = $this->getQueue($connection));
+        if (method_exists($jobRepository, 'purge')) {
+            $jobRepository->purge($queue = $this->getQueue($connection));
+        }
 
         $count = $manager->connection($connection)->clear($queue);