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

Class Netflow5UdpParser

java.lang.Object

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

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

All Implemented Interfaces:

Dispatchable, Parser, UdpParser

public class Netflow5UdpParser
extends ParserBase
implements UdpParser, Dispatchable

Field Summary

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

CLOCK_SKEW_EVENT_UEI

Constructor Summary

Constructors

Constructor and Description
Netflow5UdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, EventForwarder eventForwarder, Identity identity, DnsResolver dnsResolver, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
boolean	handles(ByteBuffer buffer) Returns true if the implementor can handle the incoming data, otherwise false.
CompletableFuture<?>	parse(ByteBuffer buffer, InetSocketAddress remoteAddress, InetSocketAddress localAddress)

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

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

Netflow5UdpParser

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

Method Detail

handles

public boolean handles(ByteBuffer 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.

parse

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

Specified by:

parse in interface UdpParser

Throws:

Exception