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