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