seperate queue for forwarding jobs

fablabbcn · Jul 10, 2024 · 8be0a0c · 8be0a0c
1 parent 09ee67d
commit 8be0a0c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/app/jobs/mqtt_forwarding_job.rb b/app/jobs/mqtt_forwarding_job.rb
@@ -1,5 +1,7 @@
 class MQTTForwardingJob < ApplicationJob
 
+  queue_as :mqtt_forward
+
   def perform(device_id, reading)
     begin
       device = Device.find(device_id)

diff --git a/config/sidekiq.yml b/config/sidekiq.yml
@@ -5,6 +5,7 @@
   - default
   - mailers
   - mqtt_retry
+  - mqtt_forward
 
 production:
   :concurrency: 25