class Sidekiq::Bunch::Middleware::Server
Public Instance Methods
call(worker, msg, _queue) { || ... }
click to toggle source
# File lib/sidekiq/bunch/middleware.rb, line 13 def call(worker, msg, _queue) bunch_id = msg['bunch_id'] if bunch_id worker.bunch_id = bunch_id result = yield Sidekiq::Bunch.new(bunch_id).on_success(msg) result else yield end end