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