class DispatchRider::Runner
Public Class Methods
run()
click to toggle source
# File lib/dispatch-rider/runner.rb, line 5 def self.run new.process end
Private Class Methods
new()
click to toggle source
# File lib/dispatch-rider/runner.rb, line 9 def initialize callbacks.invoke(:initialize) do ready set_queue_from_config end end
Public Instance Methods
process()
click to toggle source
# File lib/dispatch-rider/runner.rb, line 17 def process callbacks.invoke(:process) do logger.info "Running..." @subscriber.process end end
Private Instance Methods
ready()
click to toggle source
# File lib/dispatch-rider/runner.rb, line 29 def ready logger.info "Creating subscriber..." @subscriber = config.subscriber.new config.handlers.each do |handler_name| logger.info "Registering #{handler_name} handler..." @subscriber.register_handler(handler_name) end end
set_queue_from_config()
click to toggle source
# File lib/dispatch-rider/runner.rb, line 39 def set_queue_from_config kind = config.queue_kind info = config.queue_info logger.info "Setting #{kind} queue @ #{info.to_json} ..." @subscriber.register_queue(kind, info) @subscriber.setup_demultiplexer(kind, config.error_handler) end