class LogStash::Outputs::Daq
Public Instance Methods
receive(event)
click to toggle source
# 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()
click to toggle source
# 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