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