Package 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 java.lang.Object
implements UdpParser

Constructor Summary

Constructors

Constructor	Description
ForwardParser(java.lang.String name, AsyncDispatcher<TelemetryMessage> dispatcher)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getName()
java.util.concurrent.CompletableFuture<?>	parse(io.netty.buffer.ByteBuf buffer, java.net.InetSocketAddress remoteAddress, java.net.InetSocketAddress localAddress)
void	start(java.util.concurrent.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(java.lang.String name,
                     AsyncDispatcher<TelemetryMessage> dispatcher)

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface Parser

start

public void start(java.util.concurrent.ScheduledExecutorService executorService)

Specified by:

start in interface Parser

stop

public void stop()

Specified by:

stop in interface Parser

parse

public java.util.concurrent.CompletableFuture<?> parse(io.netty.buffer.ByteBuf buffer,
                                                       java.net.InetSocketAddress remoteAddress,
                                                       java.net.InetSocketAddress localAddress)
                                                throws java.lang.Exception

Specified by:

parse in interface UdpParser

Throws:

java.lang.Exception