Class: Sidekiq::Batch::Middleware::ClientMiddleware
- Inherits:
-
Object
- Object
- Sidekiq::Batch::Middleware::ClientMiddleware
- Defined in:
- lib/sidekiq/batch/middleware.rb
Instance Method Summary collapse
Instance Method Details
#call(_worker, msg, _queue, _redis_pool = nil) ⇒ Object
5 6 7 8 9 10 |
# File 'lib/sidekiq/batch/middleware.rb', line 5 def call(_worker, msg, _queue, _redis_pool = nil) if (bid = Thread.current[:bid]) Batch.increment_job_queue(bid) if (msg[:bid] = bid) end yield end |