Constructor and Description |
---|
ForwardParser(String name,
AsyncDispatcher<TelemetryMessage> dispatcher) |
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() |
public ForwardParser(String name, AsyncDispatcher<TelemetryMessage> dispatcher)
public void start(ScheduledExecutorService executorService)
public CompletableFuture<?> parse(io.netty.buffer.ByteBuf buffer, InetSocketAddress remoteAddress, InetSocketAddress localAddress) throws Exception
Copyright © 2020. All rights reserved.