seperate queue for mqtt retries, with custom backoff schedule

fablabbcn · May 6, 2024 · 1760d33 · 1760d33
1 parent 736ad61
commit 1760d33
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 1 deletion.
diff --git a/app/jobs/retry_mqtt_message_job.rb b/app/jobs/retry_mqtt_message_job.rb
@@ -1,5 +1,17 @@
 class RetryMQTTMessageJob < ApplicationJob
-  queue_as :default
+  queue_as :mqtt_retry
+
+  sidekiq_retry_in do |count|
+   case count
+   when 0..10 # Every 30 seconds for the first 5 minutes
+    30.seconds
+   when 11..55 # Then every minute for an hour
+     1.minute
+   else
+     false # Fallback to default backoff after an hour,
+       # see https://github.com/sidekiq/sidekiq/issues/2338
+   end
+  end
 
   def perform(topic, message)
     result = MqttMessagesHandler.handle_topic(topic, message, false)

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