class StompJob::Workers

Public Class Methods

listen!() click to toggle source

Tells main thread to sleep, and tells all workers to listen for and process any messages they receive.

# File lib/stomp_job/workers.rb, line 16
def listen!
  registered_workers.each(&:listen!)
  sleep
end
register( worker_klass ) click to toggle source
# File lib/stomp_job/workers.rb, line 9
def register( worker_klass )
  registered_workers << worker_klass unless registered_workers.include?(worker_klass)
  registered_workers
end
registered_workers() click to toggle source
# File lib/stomp_job/workers.rb, line 5
def registered_workers
  @registered_workers ||= []
end