class Sidekiq::Group::Middleware::ServerMiddleware

Public Instance Methods

call(_worker, msg, _queue) { || ... } click to toggle source
# File lib/sidekiq/group/middleware.rb, line 15
def call(_worker, msg, _queue)
  yield

  return unless msg['cid']

  Sidekiq::Group::Collection.new(msg['cid']).success(msg['jid'])
end