Sha256: cf722611afb6a7886ab67b20912c033f874f1f816a4421c4ac7bf233b96e0d44
Contents?: true
Size: 591 Bytes
Versions: 5
Compression:
Stored size: 591 Bytes
Contents
module Sidekiq::Status
# Should be in the client middleware chain
class ClientMiddleware
include Storage
# Uses msg['jid'] id and puts :queued status in the job's Redis hash
# @param [Class] worker_class if includes Sidekiq::Status::Worker, the job gets processed with the plugin
# @param [Array] msg job arguments
# @param [String] queue the queue's name
# @param [ConnectionPool] redis_pool optional redis connection pool
def call(worker_class, msg, queue, redis_pool=nil)
store_status msg['jid'], :queued, nil, redis_pool
yield
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems