org.opennms.netmgt.telemetry.protocols.netflow.parser

Class Netflow9UdpParser

java.lang.Object

org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase

org.opennms.netmgt.telemetry.protocols.netflow.parser.UdpParserBase

org.opennms.netmgt.telemetry.protocols.netflow.parser.Netflow9UdpParser

All Implemented Interfaces:

Parser, Dispatchable, UdpParser

public class Netflow9UdpParser
extends UdpParserBase
implements UdpParser, Dispatchable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Netflow9UdpParser.SessionKey

Field Summary

Fields inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.UdpParserBase

HOUSEKEEPING_INTERVAL

Fields inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase

CLOCK_SKEW_EVENT_UEI, ILLEGAL_FLOW_EVENT_UEI

Constructor Summary

Constructors

Constructor and Description
Netflow9UdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
protected byte[]	buildMessage(Iterable<Value<?>> record, RecordEnrichment enrichment)
protected UdpSessionManager.SessionKey	buildSessionKey(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
boolean	handles(io.netty.buffer.ByteBuf buffer) Returns true if the implementor can handle the incoming data, otherwise false.
protected RecordProvider	parse(Session session, io.netty.buffer.ByteBuf buffer)

Methods inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.UdpParserBase

getTemplateTimeout, parse, setTemplateTimeout, start, stop

Methods inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase

detectClockSkew, getClockSkewEventRate, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getName, getThreads, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, setThreads, transmit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.opennms.netmgt.telemetry.listeners.UdpParser

parse

Methods inherited from interface org.opennms.netmgt.telemetry.api.receiver.Parser

getName, start, stop

Constructor Detail

Netflow9UdpParser

public Netflow9UdpParser(String name,
                         AsyncDispatcher<TelemetryMessage> dispatcher,
                         EventForwarder eventForwarder,
                         Identity identity,
                         DnsResolver dnsResolver,
                         com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

parse

protected RecordProvider parse(Session session,
                               io.netty.buffer.ByteBuf buffer)
                        throws Exception

Specified by:

parse in class UdpParserBase

Throws:

Exception

handles

public boolean handles(io.netty.buffer.ByteBuf buffer)

Description copied from interface: Dispatchable

Returns true if the implementor can handle the incoming data, otherwise false.

Specified by:

handles in interface Dispatchable

Parameters:

buffer - Representing the incoming data

Returns:

true if the implementor can handle the data, otherwise false.

buildSessionKey

protected UdpSessionManager.SessionKey buildSessionKey(InetSocketAddress remoteAddress,
                                                       InetSocketAddress localAddress)

Specified by:

buildSessionKey in class UdpParserBase

buildMessage

protected byte[] buildMessage(Iterable<Value<?>> record,
                              RecordEnrichment enrichment)
                       throws IllegalFlowException

Specified by:

buildMessage in class ParserBase

Throws:

IllegalFlowException