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 Object
implements UdpParser

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Object	dumpInternalState()
String	getDescription()
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

getDescription

public String getDescription()

Specified by:

getDescription in interface Parser

dumpInternalState

public Object dumpInternalState()

Specified by:

dumpInternalState 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