class GlassOctopus::Application

@api private

Attributes

config[R]
processor[R]

Public Class Methods

new(processor) { |config| ... } click to toggle source
# File lib/glass_octopus/application.rb, line 9
def initialize(processor)
  @processor = processor
  @config    = Configuration.new
  @consumer  = nil

  yield @config
end

Public Instance Methods

connection() click to toggle source
# File lib/glass_octopus/application.rb, line 31
def connection
  config.connection_adapter.connect
end
logger() click to toggle source
# File lib/glass_octopus/application.rb, line 27
def logger
  config.logger
end
run() click to toggle source
# File lib/glass_octopus/application.rb, line 17
def run
  @consumer = Consumer.new(connection, processor, config.logger)
  @consumer.run
end
shutdown() click to toggle source
# File lib/glass_octopus/application.rb, line 22
def shutdown
  @consumer.shutdown if @consumer
  nil
end