Class: Ocular::Inputs::RabbitMQ::Input

Inherits:
Base
  • Object
show all
Defined in:
lib/ocular/inputs/rabbitmq_input.rb

Defined Under Namespace

Classes: DSLProxy, RabbitMQRunContext

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(settings_factory) ⇒ Input

Returns a new instance of Input.



28
29
30
31
32
33
34
35
36
 
# 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

Instance Attribute Details

#conn ⇒ Object (readonly)

Returns the value of attribute conn.



25
26
27
 
# File 'lib/ocular/inputs/rabbitmq_input.rb', line 25

def conn
  @conn
end

#routes ⇒ Object (readonly)

Returns the value of attribute routes.



24
25
26
 
# File 'lib/ocular/inputs/rabbitmq_input.rb', line 24

def routes
  @routes
end

#settings ⇒ Object (readonly)

Returns the value of attribute settings.



26
27
28
 
# File 'lib/ocular/inputs/rabbitmq_input.rb', line 26

def settings
  @settings
end

Instance Method Details

#start ⇒ Object 



38
39
40
 
# File 'lib/ocular/inputs/rabbitmq_input.rb', line 38

def start()

end

#stop ⇒ Object 



42
43
44
 
# File 'lib/ocular/inputs/rabbitmq_input.rb', line 42

def stop()
    @conn.close
end