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
    def call(worker_class, msg, queue)
      store_status msg['jid'], :queued
      yield
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq-status-0.4.0	lib/sidekiq-status/client_middleware.rb
sidekiq-status-0.3.2	lib/sidekiq-status/client_middleware.rb
sidekiq-status-0.3.1	lib/sidekiq-status/client_middleware.rb
sidekiq-status-0.3.0	lib/sidekiq-status/client_middleware.rb