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?