Modifier and Type | Method and Description |
---|---|
SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog> |
TelemetryMessageConsumer.getModule() |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<TelemetryMessage,TelemetryProtos.TelemetryMessageLog,TelemetryProtos.TelemetryMessageLog.Builder> |
TelemetrySinkModule.getAggregationPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
Listener.setDispatcher(AsyncDispatcher<TelemetryMessage> dispatcher) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractUdpListener.setDispatcher(AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
PacketHandler(Protocol protocol,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Modifier and Type | Method and Description |
---|---|
void |
TcpListener.setDispatcher(AsyncDispatcher<TelemetryMessage> dispatcher) |
Modifier and Type | Method and Description |
---|---|
void |
Listener.setDispatcher(AsyncDispatcher<TelemetryMessage> dispatcher) |
Constructor and Description |
---|
PacketHandler(AsyncDispatcher<TelemetryMessage> dispatcher) |
Modifier and Type | Method and Description |
---|---|
void |
UdpListener.setDispatcher(AsyncDispatcher<TelemetryMessage> dispatcher) |
Modifier and Type | Method and Description |
---|---|
static Listener |
ListenerFactory.buildListener(ListenerDefinition listenerDef,
AsyncDispatcher<TelemetryMessage> dispatcher) |
Copyright © 2018. All rights reserved.