class Sidekiq::Batch::Middleware::ClientMiddleware

Public Instance Methods

call(_worker, msg, _queue, _redis_pool = nil) { || ... } click to toggle source
# File lib/sidekiq/batch/middleware.rb, line 7
def call(_worker, msg, _queue, _redis_pool = nil)
  if (batch = Thread.current[:batch])
    batch.increment_job_queue(msg['jid']) if (msg[:bid] = batch.bid)
  end
  yield
end