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