class Sidekiq::PriorityQueue::Job
Attributes
priority[R]
subqueue[R]
Public Class Methods
new(item, queue_name = nil, priority = nil)
click to toggle source
# File lib/sidekiq/priority_queue/api.rb, line 58 def initialize(item, queue_name = nil, priority = nil) @args = nil @value = item @item = item.is_a?(Hash) ? item : parse(item) @queue = queue_name || @item['queue'] @subqueue = @item['subqueue'] @priority = priority end
Public Instance Methods
delete()
click to toggle source
# File lib/sidekiq/priority_queue/api.rb, line 67 def delete count = Sidekiq.redis do |conn| conn.zrem("priority-queue:#{@queue}", @value) end count != 0 end