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