Class: LogStash::Outputs::Daq

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/daq.rb

Instance Method Summary collapse

Instance Method Details

#receive(event) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/logstash/outputs/daq.rb', line 25

def receive(event)
  return unless output?(event)
      ip = event["ip"]
      message = event["message"]
     begin
      @logger.info('logstash received message: ')
     @perfEventProcessor.process(message, ip)
     rescue => e
         @logger.error('daq threw exception',
         :exception => e)
     end
      #
end

#register ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/logstash/outputs/daq.rb', line 17

def register
    require '/opt/oneops/artifact/current/oneops/dist/daq-1.0.0.jar'
    logConfigFile = java.net.URL.new('jar:file:///opt/oneops/artifact/current/oneops/dist/daq-1.0.0.jar!/log4j-logstash.xml');
    org.apache.log4j.xml.DOMConfigurator.configure(logConfigFile);
    @perfEventProcessor = Java::com.oneops.daq::PerfEventProcessor.new(@cluster_host_port, @cluster_name, @keyspace_name, @sensor_cluster_name, @sensor_keyspace_name, @sensor_host_port)
end