Contents

require "glass_octopus/consumer"
require "glass_octopus/configuration"

module GlassOctopus
  # @api private
  class Application
    attr_reader :config, :processor

    def initialize(processor)
      @processor = processor
      @config    = Configuration.new
      @consumer  = nil

      yield @config
    end

    def run
      @consumer = Consumer.new(connection, processor, config.logger)
      @consumer.run
    end

    def shutdown
      @consumer.shutdown if @consumer
      nil
    end

    def logger
      config.logger
    end

    def connection
      config.connection_adapter.connect
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
glass_octopus-2.2.0	lib/glass_octopus/application.rb
glass_octopus-2.1.0	lib/glass_octopus/application.rb
glass_octopus-2.0.0	lib/glass_octopus/application.rb