Class: Sidekiq::Group::Middleware::ClientMiddleware

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

Instance Method Summary collapse

Instance Method Details

#call(_worker, msg, _queue, _redis_pool = nil) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/sidekiq/group/middleware.rb', line 5

def call(_worker, msg, _queue, _redis_pool = nil)
  if (group = Thread.current[:group_collection])
    msg['cid'] = group.cid
  end

  yield
end