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

Class UdpParserBase

java.lang.Object

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

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

Direct Known Subclasses:

IpfixUdpParser, Netflow9UdpParser

public abstract class UdpParserBase
extends ParserBase

Field Summary

Fields

Modifier and Type	Field and Description
static long	HOUSEKEEPING_INTERVAL

Constructor Summary

Constructors

Constructor and Description
UdpParserBase(Protocol protocol, String name, AsyncDispatcher<TelemetryMessage> dispatcher)

Method Summary

Modifier and Type	Method and Description
protected abstract UdpSessionManager.SessionKey	buildSessionKey(InetSocketAddress remoteAddress, InetSocketAddress localAddress)
java.time.Duration	getTemplateTimeout()
CompletableFuture<?>	parse(ByteBuffer buffer, InetSocketAddress remoteAddress, InetSocketAddress localAddress)
protected abstract RecordProvider	parse(Session session, ByteBuffer buffer)
void	setTemplateTimeout(java.time.Duration templateTimeout)
void	start(ScheduledExecutorService executorService)
void	stop()

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

getName, serialize, transmit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HOUSEKEEPING_INTERVAL

public static final long HOUSEKEEPING_INTERVAL

See Also:

Constant Field Values

Constructor Detail

UdpParserBase

public UdpParserBase(Protocol protocol,
                     String name,
                     AsyncDispatcher<TelemetryMessage> dispatcher)

Method Detail

parse

protected abstract RecordProvider parse(Session session,
                                        ByteBuffer buffer)
                                 throws Exception

Throws:

Exception

buildSessionKey

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

parse

public final CompletableFuture<?> parse(ByteBuffer buffer,
                                        InetSocketAddress remoteAddress,
                                        InetSocketAddress localAddress)
                                 throws Exception

Throws:

Exception

start

public void start(ScheduledExecutorService executorService)

stop

public void stop()

getTemplateTimeout

public java.time.Duration getTemplateTimeout()

setTemplateTimeout

public void setTemplateTimeout(java.time.Duration templateTimeout)