class LogStash::Outputs::OneopsDaq

Public Instance Methods

receive(event) click to toggle source
# File lib/logstash/outputs/oneopsdaq.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() click to toggle source
# File lib/logstash/outputs/oneopsdaq.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