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