Class: Sidekiq::Status::ClientMiddleware
- Inherits:
-
Object
- Object
- Sidekiq::Status::ClientMiddleware
- Includes:
- Storage
- Defined in:
- lib/sidekiq-status/client_middleware.rb
Overview
Should be in the client middleware chain
Constant Summary
Constants included from Storage
Storage::BATCH_LIMIT, Storage::RESERVED_FIELDS
Instance Method Summary collapse
-
#call(worker_class, msg, queue, redis_pool = nil) ⇒ Object
Uses msg id and puts :queued status in the job’s Redis hash.
Instance Method Details
#call(worker_class, msg, queue, redis_pool = nil) ⇒ Object
Uses msg id and puts :queued status in the job’s Redis hash
10 11 12 13 |
# File 'lib/sidekiq-status/client_middleware.rb', line 10 def call(worker_class, msg, queue, redis_pool=nil) store_status msg['jid'], :queued, nil, redis_pool yield end |