From 56a0eade1148cc5ac45126aaeb1c58eff375e3ac Mon Sep 17 00:00:00 2001 From: Tim Otten Date: Tue, 7 Jun 2022 03:25:31 -0700 Subject: [PATCH] demoqueue - Include a userjob with the demo --- .../CRM/Demoqueue/Page/DemoQueue.php | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/tools/extensions/org.civicrm.demoqueue/CRM/Demoqueue/Page/DemoQueue.php b/tools/extensions/org.civicrm.demoqueue/CRM/Demoqueue/Page/DemoQueue.php index a63c4eea01..14e371c795 100644 --- a/tools/extensions/org.civicrm.demoqueue/CRM/Demoqueue/Page/DemoQueue.php +++ b/tools/extensions/org.civicrm.demoqueue/CRM/Demoqueue/Page/DemoQueue.php @@ -6,13 +6,14 @@ require_once 'CRM/Core/Page.php'; * An example page which queues several tasks and then executes them */ class CRM_Demoqueue_Page_DemoQueue extends CRM_Core_Page { - const QUEUE_NAME = 'demo-queue'; function run() { - $queue = CRM_Queue_Service::singleton()->create([ + $queueName = 'demoqueue_' . time(); + + $queue = Civi::queue($queueName, [ 'type' => 'Sql', - 'name' => self::QUEUE_NAME, - 'reset' => TRUE, + 'runner' => 'task', + 'error' => 'abort', ]); for ($i = 0; $i < 5; $i++) { @@ -30,6 +31,12 @@ class CRM_Demoqueue_Page_DemoQueue extends CRM_Core_Page { } } + \Civi\Api4\UserJob::create()->setValues([ + 'type_id:label' => 'Contact Import', + 'status_id:name' => 'in_progress', + 'queue_id.name' => $queue->getName(), + ])->execute(); + $runner = new CRM_Queue_Runner([ 'title' => ts('Demo Queue Runner'), 'queue' => $queue, -- 2.25.1