class DispatchRider::Runner

Public Class Methods

run() click to toggle source
# File lib/dispatch-rider/runner.rb, line 7
def self.run
  new.process
end

Private Class Methods

new() click to toggle source
# File lib/dispatch-rider/runner.rb, line 11
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 19
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 31
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 41
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