class Sidekiq::Haron::ClientMiddleware

Public Instance Methods

call(worker_class, msg, queue, redis_pool=nil) { || ... } click to toggle source
# File lib/sidekiq/haron/client_middleware.rb, line 5
def call(worker_class, msg, queue, redis_pool=nil)
  if msg['retry_count'].blank? # don't store on retry
    Sidekiq::Haron.transmitter.save(worker_class, msg, queue, redis_pool)
  end
  yield
end