Contents

module DispatchRider
  class Runner

    def self.run
      new.process
    end

    def initialize
      callbacks.invoke(:initialize) do
        ready
        set_queue_from_config
      end
    end
    private_class_method :new

    def process
      callbacks.invoke(:process) do
        puts "Running..."
        @subscriber.process
      end
    end

    private

    def config
      DispatchRider.config
    end

    def callbacks
      @callbacks ||= Callbacks::Access.new(config.callbacks)
    end

    def logger
      config.logger
    end

    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

    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

  end
end

Version data entries

30 entries across 30 versions & 1 rubygems

Version	Path
dispatch-rider-1.4.2	lib/dispatch-rider/runner.rb
dispatch-rider-1.4.0	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.6	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.5	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.4	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.3	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.2	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.1	lib/dispatch-rider/runner.rb
dispatch-rider-1.3.0	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.11	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.10	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.9	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.8	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.7	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.6	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.5	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.4	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.3	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.2	lib/dispatch-rider/runner.rb
dispatch-rider-1.2.1	lib/dispatch-rider/runner.rb