org.opennms.netmgt.telemetry.protocols.common.parser

Class ForwardParser

java.lang.Object

org.opennms.netmgt.telemetry.protocols.common.parser.ForwardParser

All Implemented Interfaces:

Parser, UdpParser

public class ForwardParser
extends Object
implements UdpParser

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
String	getName()
CompletableFuture<?>	parse(io.netty.buffer.ByteBuf 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

ForwardParser

public ForwardParser(String name,
                     AsyncDispatcher<TelemetryMessage> dispatcher)

Method Detail

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

parse

public CompletableFuture<?> parse(io.netty.buffer.ByteBuf buffer,
                                  InetSocketAddress remoteAddress,
                                  InetSocketAddress localAddress)
                           throws Exception

Specified by:

parse in interface UdpParser

Throws:

Exception