Sha256: 384bea1f02ee7b7e09940152782f23ef97ae5d1994f8bc3d286d19efb9b1eeae
Contents?: true
Size: 937 Bytes
Versions: 7
Compression:
Stored size: 937 Bytes
Contents
module Sidetiq
module Actor
def self.included(base)
base.__send__(:include, Celluloid)
base.finalizer :sidetiq_finalizer
end
def initialize(*args, &block)
log_call "initialize"
super
# Link to Sidekiq::Manager when running in server-mode. In most
# cases the supervisor is booted before Sidekiq has launched
# fully, so defer this.
if Sidekiq.server?
after(0.1) { link_to_sidekiq_manager }
end
end
private
def sidetiq_finalizer
log_call "shutting down ..."
end
def link_to_sidekiq_manager
Sidekiq::CLI.instance.launcher.manager.link(current_actor)
rescue NoMethodError
warn "Can't link #{self.class.name}. Sidekiq::Manager not running. Retrying in 5 seconds ..."
after(5) { link_to_sidekiq_manager }
end
def log_call(call)
info "#{self.class.name} id: #{object_id} #{call}"
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems