Class: Jober::SlowQueue

Inherits:
Queue show all
Defined in:
lib/jober/slow_queue.rb

Instance Attribute Summary

Attributes inherited from AbstractTask

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

Instance Method Summary collapse

Methods inherited from Queue

dequeue, enqueue, inherited, len, #len, #pop, #queue_name, #retry_event, #retry_event_later, set_queue_name

Methods inherited from Task

extract_name, inherited, #perform

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

Instance Method Details

#run ⇒ Object

one event per perform



4
5
6
7
8
9
10
11
 
# File 'lib/jober/slow_queue.rb', line 4

def run
  if @args = pop
    perform(*@args)
    info { "processed event args: #{@args.inspect}" }
  else
    info { "no pending events" }
  end
end