class Sidekiq::Haron::ServerMiddleware

Public Instance Methods

call(worker, msg, queue) { || ... } click to toggle source
# File lib/sidekiq/haron/server_middleware.rb, line 5
def call(worker, msg, queue)
  Sidekiq::Haron.transmitter.load(msg['jid'])
  yield
  # job successfully end
  Sidekiq::Haron.transmitter.clean(msg['jid'])
end