Class: Sidekiq::Web

Inherits:

Sinatra::Base

• Object
• Sinatra::Base
• Sidekiq::Web

Defined in:

lib/sidekiq/web.rb

Instance Method Summary

• #process_score(set, score, operation) ⇒ Object

Instance Method Details

#process_score(set, score, operation) ⇒ Object

# File 'lib/sidekiq/web.rb', line 190

def process_score(set, score, operation)
  case operation
  when :retry
    Sidekiq.redis do |conn|
      results = conn.zrangebyscore(set, score, score)
      conn.zremrangebyscore(set, score, score)
      results.map do |message|
        msg = Sidekiq.load_json(message)
        msg['retry_count'] = msg['retry_count'] - 1
        conn.rpush("queue:#{msg['queue']}", Sidekiq.dump_json(msg))
      end
    end
  when :delete
    Sidekiq.redis do |conn|
      conn.zremrangebyscore(set, score, score)
    end
  end
end