From ffd338e287a65263c442d025b3a82245c99b18ae Mon Sep 17 00:00:00 2001
From: Dillon Ngo <dillonngoweijoon@gmail.com>
Date: Thu, 14 Mar 2024 16:29:26 +0800
Subject: [PATCH] Vue Polling - Second high priority queue through database

---
 .../Bookings/ControllersLogic/ListBookingJobLogic.php      | 2 +-
 .../Documents/ControllersLogic/ListDocumentJobLogic.php    | 2 +-
 .../ControllersLogic/ListTransactionsJobLogic.php          | 2 +-
 config/queue.php                                           | 7 +++++++
 4 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/app/Classes/Modules/Bookings/ControllersLogic/ListBookingJobLogic.php b/app/Classes/Modules/Bookings/ControllersLogic/ListBookingJobLogic.php
index ef3570f7..ce7d5a85 100644
--- a/app/Classes/Modules/Bookings/ControllersLogic/ListBookingJobLogic.php
+++ b/app/Classes/Modules/Bookings/ControllersLogic/ListBookingJobLogic.php
@@ -62,7 +62,7 @@ class ListBookingJobLogic extends AbstractControllerLogic
             $userInfo
         );
 
-        ListBookingsJob::dispatch($listGenericJobObject);
+        ListBookingsJob::dispatch($listGenericJobObject)->onQueue('high_priority');
 
         $result = [];
         $result['job_id'] = $jobId;
diff --git a/app/Classes/Modules/Documents/ControllersLogic/ListDocumentJobLogic.php b/app/Classes/Modules/Documents/ControllersLogic/ListDocumentJobLogic.php
index 5e895ad8..f803494a 100644
--- a/app/Classes/Modules/Documents/ControllersLogic/ListDocumentJobLogic.php
+++ b/app/Classes/Modules/Documents/ControllersLogic/ListDocumentJobLogic.php
@@ -63,7 +63,7 @@ class ListDocumentJobLogic extends AbstractControllerLogic
             $userInfo
         );
 
-        ListDocumentsJob::dispatch($listGenericJobObject);
+        ListDocumentsJob::dispatch($listGenericJobObject)->onQueue('high_priority');
 
         $result = [];
         $result['job_id'] = $jobId;
diff --git a/app/Classes/Modules/Transactions/ControllersLogic/ListTransactionsJobLogic.php b/app/Classes/Modules/Transactions/ControllersLogic/ListTransactionsJobLogic.php
index 654a360f..a9147c49 100644
--- a/app/Classes/Modules/Transactions/ControllersLogic/ListTransactionsJobLogic.php
+++ b/app/Classes/Modules/Transactions/ControllersLogic/ListTransactionsJobLogic.php
@@ -61,7 +61,7 @@ class ListTransactionsJobLogic extends AbstractControllerLogic
             $userInfo
         );
 
-        ListTransactionsJob::dispatch($listGenericJobObject);
+        ListTransactionsJob::dispatch($listGenericJobObject)->onQueue('high_priority');
 
         $result = [];
         $result['job_id'] = $jobId;
diff --git a/config/queue.php b/config/queue.php
index 00b76d65..fc718e49 100644
--- a/config/queue.php
+++ b/config/queue.php
@@ -34,6 +34,13 @@ return [
             'driver' => 'sync',
         ],
 
+        'high_priority' => [
+            'driver' => 'database',
+            'table' => 'jobs',
+            'queue' => 'high_priority',
+            'retry_after' => 90,
+        ],
+
         'database' => [
             'driver' => 'database',
             'table' => 'jobs',