Class: Fluent::Plugin::UdpHandler

Inherits:
Coolio::IO
  • Object
show all
Defined in:
lib/fluent/plugin/in_netflowipfix.rb

Overview

class NetflowipfixInput

Instance Method Summary collapse

Constructor Details

#initialize(io, callback) ⇒ UdpHandler

Returns a new instance of UdpHandler.



136
137
138
139
140
 
# File 'lib/fluent/plugin/in_netflowipfix.rb', line 136

def initialize(io, callback)
	super(io)
	@io = io
	@callback = callback
end

Instance Method Details

#on_readable ⇒ Object

def initialize



142
143
144
145
146
147
148
 
# File 'lib/fluent/plugin/in_netflowipfix.rb', line 142

def on_readable
	msg, addr = @io.recvfrom_nonblock(4096)
	@callback.call(addr[3], msg)
	rescue => e
		log.error "unexpected error on reading from socket", error_class: e.class, error: e.message
	log.error_backtrace
end