CRM_Queue_Service - Extract method resetQueue

CRM/Queue/Queue.php

@@ -142,6 +142,14 @@ abstract class CRM_Queue_Queue {
    */
   abstract public function existsQueue();
 
+  /**
+   * Delete all items in the queue.
+   */
+  public function resetQueue(): void {
+    $this->deleteQueue();
+    $this->createQueue();
+  }
+
   /**
    * Add a new item to the queue.
    *

CRM/Queue/Service.php

@@ -115,8 +115,7 @@ class CRM_Queue_Service {
       $queue->createQueue();
     }
     elseif (@$queueSpec['reset']) {
-      $queue->deleteQueue();
-      $queue->createQueue();
+      $queue->resetQueue();
     }
     else {
       $queue->loadQueue();