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

Class SFlowUdpParser

java.lang.Object

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

All Implemented Interfaces:

Dispatchable, Parser, UdpParser

public class SFlowUdpParser
extends Object
implements UdpParser, Dispatchable

Constructor Summary

Constructors

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

Method Summary

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

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

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