class Ocular::Inputs::RabbitMQ::Input

Attributes

conn[R]
routes[R]
settings[R]

Public Class Methods

new(settings_factory) click to toggle source
# File lib/ocular/inputs/rabbitmq_input.rb, line 28
def initialize(settings_factory)
    @settings = settings_factory.get(:datasources).fetch(:rabbitmq, {})

    url = @settings[:url] || nil
    ::Ocular.logger.debug "Starting RabbitMQ input with connection string #{url}"

    @conn = Bunny.new(url)
    @conn.start
end

Public Instance Methods

start() click to toggle source
# File lib/ocular/inputs/rabbitmq_input.rb, line 38
def start()

end
stop() click to toggle source
# File lib/ocular/inputs/rabbitmq_input.rb, line 42
def stop()
    @conn.close
end