Class: Sidekiq::PriorityQueue::Job

Inherits:
JobRecord
  • Object
show all
Defined in:
lib/sidekiq/priority_queue/api.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(item, queue_name = nil, priority = nil) ⇒ Job

Returns a new instance of Job.



58
59
60
61
62
63
64
65
 
# 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

Instance Attribute Details

#priority ⇒ Object (readonly)

Returns the value of attribute priority.



55
56
57
 
# File 'lib/sidekiq/priority_queue/api.rb', line 55

def priority
  @priority
end

#subqueue ⇒ Object (readonly)

Returns the value of attribute subqueue.



56
57
58
 
# File 'lib/sidekiq/priority_queue/api.rb', line 56

def subqueue
  @subqueue
end

Instance Method Details

#delete ⇒ Object 



67
68
69
70
71
72
 
# 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