lib/sidekiq-status/client_middleware.rb in sidekiq-status-0.4.0 vs lib/sidekiq-status/client_middleware.rb in sidekiq-status-0.5.0
- old
+ new
@@ -4,11 +4,12 @@
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
- def call(worker_class, msg, queue)
- store_status msg['jid'], :queued
+ # @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