lib/sidekiq/limit_fetch/global/monitor.rb in sidekiq-limit_fetch-3.2.1 vs lib/sidekiq/limit_fetch/global/monitor.rb in sidekiq-limit_fetch-3.3.0

@@ -8,12 +8,15 @@
     REFRESH_TIMEOUT = 5
 
     def start!(ttl=HEARTBEAT_TTL, timeout=REFRESH_TIMEOUT)
       Thread.new do
         loop do
-          add_dynamic_queues
-          update_heartbeat ttl
-          invalidate_old_processes
+          Sidekiq::LimitFetch.redis_retryable do
+            add_dynamic_queues
+            update_heartbeat ttl
+            invalidate_old_processes
+          end
+
           sleep timeout
         end
       end
     end