threshold warning logic

fablabbcn · Oct 22, 2024 · a728506 · a728506
1 parent 2adfd21
commit a728506
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/tasks/mqtt_subscriber.rake b/lib/tasks/mqtt_subscriber.rake
@@ -60,9 +60,11 @@ namespace :mqtt do
               end
               mqtt_log.info "Processed MQTT message in #{time}"
               mqtt_log.info "MQTT queue length: #{client.queue_length}"
-              if !threshold_passed && client.queue_length >= mqtt_queue_length_warning_threshold
-                threshold_passed = true
-                Sentry.capture_message("Warning: Internal MQTT queue length is #{client.queue_length} (>= #{mqtt_queue_length_warning_threshold} on client #{mqtt_client_id}).")
+              if client.queue_length >= mqtt_queue_length_warning_threshold
+                if !threshold_passed
+                  Sentry.capture_message("Warning: Internal MQTT queue length is #{client.queue_length} (>= #{mqtt_queue_length_warning_threshold} on client #{mqtt_client_id}).")
+                  threshold_passed = true
+                end
               else
                 threshold_passed = false
               end