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

Class IpfixUdpParser

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

All Implemented Interfaces:

Parser, Dispatchable, UdpParser

public class IpfixUdpParser
extends UdpParserBase
implements UdpParser, Dispatchable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IpfixUdpParser.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	Description
IpfixUdpParser(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)
Long	getFlowActiveTimeoutFallback()
Long	getFlowInactiveTimeoutFallback()
Long	getFlowSamplingIntervalFallback()
IpFixMessageBuilder	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)
void	setFlowActiveTimeoutFallback(Long flowActiveTimeoutFallback)
void	setFlowInactiveTimeoutFallback(Long flowInactiveTimeoutFallback)
void	setFlowSamplingIntervalFallback(Long flowSamplingIntervalFallback)

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

IpfixUdpParser

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

Method Detail

getMessageBuilder

public IpFixMessageBuilder getMessageBuilder()

Specified by:

getMessageBuilder in class ParserBase

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

getFlowActiveTimeoutFallback

public Long getFlowActiveTimeoutFallback()

setFlowActiveTimeoutFallback

public void setFlowActiveTimeoutFallback(Long flowActiveTimeoutFallback)

getFlowInactiveTimeoutFallback

public Long getFlowInactiveTimeoutFallback()

setFlowInactiveTimeoutFallback

public void setFlowInactiveTimeoutFallback(Long flowInactiveTimeoutFallback)

getFlowSamplingIntervalFallback

public Long getFlowSamplingIntervalFallback()

setFlowSamplingIntervalFallback

public void setFlowSamplingIntervalFallback(Long flowSamplingIntervalFallback)