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