Method: Sidekiq::JobSet#delete_by_jid

Defined in:
lib/sidekiq/api.rb

#delete_by_jid(score, jid) ⇒ Object Also known as: delete 



566
567
568
569
570
571
572
573
574
575
576
577
578
579
 
# File 'lib/sidekiq/api.rb', line 566

def delete_by_jid(score, jid)
  Sidekiq.redis do |conn|
    elements = conn.zrangebyscore(name, score, score)
    elements.each do |element|
      message = Sidekiq.load_json(element)
      if message["jid"] == jid
        ret = conn.zrem(name, element)
        @_size -= 1 if ret
        break ret
      end
      false
    end
  end
end