priority queue

app/Jobs/ProcessANPCAllData.php

@@ -50,8 +50,8 @@ public function handle()
 
         $this->handleIncidents($incidents);
 
-        dispatch(new CheckIsActive($incidents));
-        dispatch(new CheckImportantFireIncident());
+        dispatch((new CheckIsActive($incidents))->onQueue('high'));
+        dispatch((new CheckImportantFireIncident())->onQueue('low'));
     }
 
     private function handleIncidents($data)

app/Jobs/ProcessICNFPDFData.php

@@ -87,7 +87,7 @@ public function handle()
                 $fileId = $match[1];
                 $url = env('ICNF_PDF_URL').$fileId;
 
-                dispatch(new ProcessICNFPDF($this->incident[0], $url));
+                dispatch((new ProcessICNFPDF($this->incident[0], $url))->onQueue('low'));
             }
         }
     }

app/Jobs/UpdateICNFData.php

@@ -82,7 +82,7 @@ public function handle()
             ->get();
 
         foreach ($incidents as $incident) {
-            dispatch(new ProcessICNFFireData($incident));
+            dispatch((new ProcessICNFFireData($incident))->onQueue('low'));
         }
     }
 }

app/Observers/IncidentObserver.php

@@ -16,18 +16,19 @@ protected static function boot()
 
         static::created(function ($incident) {
             //Log::info("Incident Created Event Fire observer: ".$incident);
-            dispatch(new SaveIncidentHistory($incident));
-            dispatch(new SaveIncidentStatusHistory($incident));
+            dispatch((new SaveIncidentHistory($incident))->onQueue('low'));
+            dispatch((new SaveIncidentStatusHistory($incident))->onQueue('low'));
+            dispatch((new SaveIncidentStatusHistory($incident))->onQueue('low'));
             if ($incident->isFire) {
-                dispatch(new HandleNewIncidentSocialMedia($incident));
-                dispatch(new ProcessICNFFireData($incident));
+                dispatch((new HandleNewIncidentSocialMedia($incident))->onQueue('high'));
+                dispatch((new ProcessICNFFireData($incident))->onQueue('low'));
             }
         });
 
         static::updated(function ($incident) {
             //Log::info("Incident updated Event Fire observer: ".$incident);
-            dispatch(new SaveIncidentStatusHistory($incident));
-            dispatch(new SaveIncidentHistory($incident));
+            dispatch((new SaveIncidentStatusHistory($incident))->onQueue('low'));
+            dispatch((new SaveIncidentHistory($incident))->onQueue('low'));
         });
 
         static::deleted(function ($incident) {

config/queue.php

@@ -0,0 +1,59 @@
+<?php
+
+return [
+
+    /*
+    |--------------------------------------------------------------------------
+    | Default Queue Connection Name
+    |--------------------------------------------------------------------------
+    |
+    | Laravel's queue API supports an assortment of back-ends via a single
+    | API, giving you convenient access to each back-end using the same
+    | syntax for every one. Here you may define a default connection.
+    |
+    */
+
+    'default' => env('QUEUE_CONNECTION', 'sync'),
+
+    /*
+    |--------------------------------------------------------------------------
+    | Queue Connections
+    |--------------------------------------------------------------------------
+    |
+    | Here you may configure the connection information for each server that
+    | is used by your application. A default configuration has been added
+    | for each back-end shipped with Laravel. You are free to add more.
+    |
+    | Drivers: "sync", "database", "beanstalkd", "sqs", "redis", "null"
+    |
+    */
+
+    'connections' => [
+        'redis' => [
+            'driver' => 'redis',
+            'connection' => 'default',
+            'queue' => env('REDIS_QUEUE', 'default'),
+            'retry_after' => 90,
+            'block_for' => null,
+            'after_commit' => false,
+        ],
+        'redis_high' => [
+            'driver' => 'redis',
+            'connection' => 'default',
+            'queue' => 'high',
+            'retry_after' => 90,
+            'block_for' => null,
+            'after_commit' => false,
+        ],
+        'redis_low' => [
+            'driver' => 'redis',
+            'connection' => 'default',
+            'queue' => 'low',
+            'retry_after' => 90,
+            'block_for' => null,
+            'after_commit' => false,
+        ],
+    ],
+
+
+];

docker-compose.yml

@@ -87,7 +87,7 @@ services:
       - fogos.mongodb
     networks:
       - fogos
-    command: php artisan queue:work --sleep=3 --tries=3 --max-time=3600
+    command: php artisan queue:work --queue=high,default,low --sleep=3 --tries=3 --max-time=3600
 
 volumes:
   mongodb_data: