lib/sidekiq/grouping/actor.rb in sidekiq-grouping-1.0.2 vs lib/sidekiq/grouping/actor.rb in sidekiq-grouping-1.0.3

- old
+ new

@@ -7,11 +7,11 @@ def initialize link_to_sidekiq_manager end private - + def start_polling interval = Sidekiq::Grouping::Config.poll_interval info "Start polling of queue batches every #{interval} seconds" every(interval) { flush_batches } end @@ -27,13 +27,12 @@ flush(batches) end def link_to_sidekiq_manager - Sidekiq::CLI.instance.launcher.manager.link(current_actor) start_polling - rescue NoMethodError - debug "Can't link #{self.class.name}. Sidekiq::Manager not running. Retrying in 5 seconds ..." + rescue + info "Can't link #{self.class.name}. Sidekiq::Manager not running. Retrying in 5 seconds ..." after(5) { link_to_sidekiq_manager } end def flush(batches) if batches.any?