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

Class IpfixTcpParser

java.lang.Object

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

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

All Implemented Interfaces:

Parser, TcpParser

public class IpfixTcpParser
extends ParserBase
implements TcpParser

Nested Class Summary

Nested classes/interfaces inherited from interface org.opennms.netmgt.telemetry.listeners.TcpParser

TcpParser.Handler

Field Summary

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

Method Summary

Modifier and Type	Method	Description
TcpParser.Handler	accept(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
Object	dumpInternalState()
Long	getFlowActiveTimeoutFallback()
Long	getFlowInactiveTimeoutFallback()
Long	getFlowSamplingIntervalFallback()
IpFixMessageBuilder	getMessageBuilder()
void	setFlowActiveTimeoutFallback(Long flowActiveTimeoutFallback)
void	setFlowInactiveTimeoutFallback(Long flowInactiveTimeoutFallback)
void	setFlowSamplingIntervalFallback(Long flowSamplingIntervalFallback)

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, start, stop, 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

getDescription, getName, start, stop

Constructor Detail

IpfixTcpParser

public IpfixTcpParser(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

accept

public TcpParser.Handler accept(InetSocketAddress remoteAddress,
                                InetSocketAddress localAddress)

Specified by:

accept in interface TcpParser

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)

dumpInternalState

public Object dumpInternalState()

Specified by:

dumpInternalState in interface Parser