Class IpfixTcpParser
- java.lang.Object
-
- org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase
-
- org.opennms.netmgt.telemetry.protocols.netflow.parser.IpfixTcpParser
-
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(java.lang.String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description TcpParser.Handler
accept(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
java.lang.Long
getFlowActiveTimeoutFallback()
java.lang.Long
getFlowInactiveTimeoutFallback()
IpFixMessageBuilder
getMessageBuilder()
void
setFlowActiveTimeoutFallback(java.lang.Long flowActiveTimeoutFallback)
void
setFlowInactiveTimeoutFallback(java.lang.Long flowInactiveTimeoutFallback)
-
Methods inherited from class org.opennms.netmgt.telemetry.protocols.netflow.parser.ParserBase
detectClockSkew, getClockSkewEventRate, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getName, getSequenceNumberPatience, getThreads, sequenceNumberTracker, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, setSequenceNumberPatience, setThreads, start, stop, transmit
-
-
-
-
Constructor Detail
-
IpfixTcpParser
public IpfixTcpParser(java.lang.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 classParserBase
-
accept
public TcpParser.Handler accept(java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
-
getFlowActiveTimeoutFallback
public java.lang.Long getFlowActiveTimeoutFallback()
-
setFlowActiveTimeoutFallback
public void setFlowActiveTimeoutFallback(java.lang.Long flowActiveTimeoutFallback)
-
getFlowInactiveTimeoutFallback
public java.lang.Long getFlowInactiveTimeoutFallback()
-
setFlowInactiveTimeoutFallback
public void setFlowInactiveTimeoutFallback(java.lang.Long flowInactiveTimeoutFallback)
-
-