ForwardInput
obsolete ForwardInput is backward compatible with TcpInput
class TcpInput < StreamInput
Plugin.register_input('tcp', self) config_param :port, :integer, :default => DEFAULT_LISTEN_PORT config_param :bind, :string, :default => '0.0.0.0' def configure(conf) super end def listen $log.debug "listening fluent socket on #{@bind}:#{@port}" Coolio::TCPServer.new(@bind, @port, Handler, method(:on_message)) end
end
Generated with the Darkfish Rdoc Generator 2.