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

Method Summary

Modifier and Type	Method and Description
TcpParser.Handler	accept(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
protected byte[]	buildMessage(Iterable<Value<?>> record, RecordEnrichment enrichment)

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

detectClockSkew, getClockSkewEventRate, getDnsLookupsEnabled, getIllegalFlowEventRate, getMaxClockSkew, getName, getThreads, setClockSkewEventRate, setDnsLookupsEnabled, setIllegalFlowEventRate, setMaxClockSkew, 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

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

accept

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

Specified by:

accept in interface TcpParser

buildMessage

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

Specified by:

buildMessage in class ParserBase

Throws:

IllegalFlowException