class Sidekiq::Group::Middleware::ClientMiddleware
Public Instance Methods
call(_worker, msg, _queue, _redis_pool = nil) { || ... }
click to toggle source
# 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