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

Class Netflow5UdpParser

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.Netflow5UdpParser

All Implemented Interfaces:

Parser, Dispatchable, UdpParser

public class Netflow5UdpParser
extends UdpParserBase
implements UdpParser, Dispatchable

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	Description
Netflow5UdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method	Description
protected UdpSessionManager.SessionKey	buildSessionKey(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
Netflow5MessageBuilder	getMessageBuilder()
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

dumpInternalState, getTemplateTimeout, parse, setTemplateTimeout, start, stop

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

detectClockSkew, getClockSkewEventRate, getDescription, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getName, getSequenceNumberPatience, getThreads, sequenceNumberTracker, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, setSequenceNumberPatience, 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.api.receiver.Parser

dumpInternalState, getDescription, getName, start, stop

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

parse

Constructor Detail

Netflow5UdpParser

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

Method Detail

getMessageBuilder

public Netflow5MessageBuilder getMessageBuilder()

Specified by:

getMessageBuilder in class ParserBase

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.

parse

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

Specified by:

parse in class UdpParserBase

Throws:

Exception

buildSessionKey

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

Specified by:

buildSessionKey in class UdpParserBase