Class: Sidekiq::Group::Middleware::ServerMiddleware

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/group/middleware.rb

Instance Method Summary collapse

Instance Method Details

#call(_worker, msg, _queue) ⇒ Object 



15
16
17
18
19
20
21
 
# 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