Class: Jober::UniqueQueue

Inherits:

Queue

• Object
• AbstractTask
• Task
• Queue
• Jober::UniqueQueue

Defined in:

lib/jober/unique_queue.rb

Direct Known Subclasses

UniqueQueueBatch

Instance Attribute Summary

Attributes inherited from AbstractTask

#finished, #stopped, #unique_id, #worker_id, #workers_count

Class Method Summary

• .enqueue(*args) ⇒ Object
• .len ⇒ Object

Instance Method Summary

• #pop ⇒ Object

Methods inherited from Queue

dequeue, inherited, #len, #queue_name, #retry_event, #retry_event_later, #run, set_queue_name

Methods inherited from Task

extract_name, inherited, #perform, #run

Methods inherited from AbstractTask

#after_execute, #after_initialize, #before_execute, #execute, get_interval, get_workers, inherited, #initialize, interval, manual!, manual?, #on_crashed, #run_loop, #sleeping, #stop!, workers

Methods included from Exception

#catch, #exception

Methods included from Logger

#logger, #logger=, #logger_tag

Constructor Details

This class inherits a constructor from Jober::AbstractTask

Class Method Details

.enqueue(*args) ⇒ Object

# File 'lib/jober/unique_queue.rb', line 7

def self.enqueue(*args)
  Jober.redis.sadd(queue_name, Jober.dump_args(*args))
end

.len ⇒ Object

# File 'lib/jober/unique_queue.rb', line 3

def self.len
  Jober.redis.scard(queue_name)
end

Instance Method Details

#pop ⇒ Object

# File 'lib/jober/unique_queue.rb', line 11

def pop
  res = Jober.redis.spop(queue_name)
  Jober.load(res) if res
end