diff --git a/src/Console/Commands/ClearRequestQueue.php b/src/Console/Commands/ClearRequestQueue.php index 2b6b57c..27f3c61 100644 --- a/src/Console/Commands/ClearRequestQueue.php +++ b/src/Console/Commands/ClearRequestQueue.php @@ -32,7 +32,13 @@ public function handle() $queue = config('statamic-cache-requester.queue.name'); try { - Artisan::call("queue:clear {$connection} --queue={$queue} --force"); + if($connection == 'default') { + Artisan::call("queue:clear --queue={$queue} --force"); + } + else { + Artisan::call("queue:clear {$connection} --queue={$queue} --force"); + } + $this->info("{$connection}:{$queue} queue has been cleared"); } catch(\Throwable $e){