class MultipleMan::SidekiqMiddleware
Public Instance Methods
call(worker, job, queue) { || ... }
click to toggle source
# File lib/multiple_man_sidekiq/middleware/sidekiq_middleware.rb, line 3 def call(worker, job, queue) establish_channel if is_middleman_job? yield ensure close_channel if is_middleman_job? end
close_channel()
click to toggle source
# File lib/multiple_man_sidekiq/middleware/sidekiq_middleware.rb, line 14 def close_channel connection = Thread.local[:multiple_man_connection] connection.close_channel if connection && connection.open_channel? end
establish_channel()
click to toggle source
# File lib/multiple_man_sidekiq/middleware/sidekiq_middleware.rb, line 10 def establish_channel Thread.local[:multiple_man_connection] = MultipleMan::Connection.new end
is_middleman_job?()
click to toggle source
# File lib/multiple_man_sidekiq/middleware/sidekiq_middleware.rb, line 19 def is_middleman_job? worker.kind_of? MultipleMan::ModelPublisherJob end