org.opennms.netmgt.telemetry.protocols.sflow.parser

Class SFlowUdpParser

java.lang.Object

org.opennms.netmgt.telemetry.protocols.sflow.parser.SFlowUdpParser

All Implemented Interfaces:

Parser, Dispatchable, UdpParser

public class SFlowUdpParser
extends Object
implements UdpParser, Dispatchable

Constructor Summary

Constructors

Constructor and Description
SFlowUdpParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher, DnsResolver dnsResolver)

Method Summary

Modifier and Type	Method and Description
boolean	getDnsLookupsEnabled()
String	getName()
int	getThreads()
boolean	handles(io.netty.buffer.ByteBuf buffer) Returns true if the implementor can handle the incoming data, otherwise false.
CompletableFuture<?>	parse(io.netty.buffer.ByteBuf buffer, InetSocketAddress remoteAddress, InetSocketAddress localAddress)
void	setDnsLookupsEnabled(boolean dnsLookupsEnabled)
void	setThreads(int threads)
void	start(ScheduledExecutorService executorService)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

SFlowUdpParser

public SFlowUdpParser(String name,
                      AsyncDispatcher<TelemetryMessage> dispatcher,
                      DnsResolver dnsResolver)

Method Detail

handles

public boolean handles(io.netty.buffer.ByteBuf 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(io.netty.buffer.ByteBuf buffer,
                                  InetSocketAddress remoteAddress,
                                  InetSocketAddress localAddress)
                           throws Exception

Specified by:

parse in interface UdpParser

Throws:

Exception

getDnsLookupsEnabled

public boolean getDnsLookupsEnabled()

setDnsLookupsEnabled

public void setDnsLookupsEnabled(boolean dnsLookupsEnabled)

getName

public String getName()

Specified by:

getName in interface Parser

start

public void start(ScheduledExecutorService executorService)

Specified by:

start in interface Parser

stop

public void stop()

Specified by:

stop in interface Parser

getThreads

public int getThreads()

setThreads

public void setThreads(int threads)