class Sidekiq::Bunch::Middleware::Client

Public Instance Methods

call(_worker_class, msg, _queue, _redis_pool) { || ... } click to toggle source
# File lib/sidekiq/bunch/middleware.rb, line 5
def call(_worker_class, msg, _queue, _redis_pool)
  bunch = Thread.current[:sidekiq_bunch]
  msg['bunch_id'] = bunch.bunch_id if bunch
  yield
end