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