X-Git-Url: https://vcs.fsf.org/?a=blobdiff_plain;f=Civi.php;h=86e72ee847e75d959623c1e297267b3c9c55c3e7;hb=31f66367b0902d539a7ab0c800f2dc5963caf7d5;hp=9e4b8dcbfd764a9e0243b80c7a0e54484d88ca19;hpb=3e60b6fb7b76c46f54247e87733bbb1e76d0cb54;p=civicrm-core.git

diff --git a/Civi.php b/Civi.php
index 9e4b8dcbfd..86e72ee847 100644
--- a/Civi.php
+++ b/Civi.php
@@ -105,6 +105,30 @@ class Civi {
     return \Civi\Core\Container::getBootService('paths');
   }
 
+  /**
+   * Fetch a queue object.
+   *
+   * Note: Historically, `CRM_Queue_Queue` objects were not persistently-registered. Persistence
+   * is now encouraged. This facade has a bias towards persistently-registered queues.
+   *
+   * @param string $name
+   *   The name of a persistent/registered queue (stored in `civicrm_queue`)
+   * @param array{type: string, is_autorun: bool, reset: bool, is_persistent: bool} $params
+   *   Specification for a queue.
+   *   This is not required for accessing an existing queue.
+   *   Specify this if you wish to auto-create the queue or to include advanced options (eg `reset`).
+   *   Example: ['type' => 'Sql', 'error' => 'abort']
+   *   Example: ['type' => 'SqlParallel', 'error' => 'delete']
+   *   Defaults: ['reset'=>FALSE, 'is_persistent'=>TRUE, 'is_autorun'=>FALSE]
+   * @return \CRM_Queue_Queue
+   * @see \CRM_Queue_Service
+   */
+  public static function queue(string $name, array $params = []): CRM_Queue_Queue {
+    $defaults = ['reset' => FALSE, 'is_persistent' => TRUE, 'status' => 'active'];
+    $params = array_merge($defaults, $params, ['name' => $name]);
+    return CRM_Queue_Service::singleton()->create($params);
+  }
+
   /**
    * Obtain the formatting object.
    *