public class TelemetryMessageConsumer extends Object implements MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
Constructor and Description |
---|
TelemetryMessageConsumer(Protocol protocol,
TelemetrySinkModule sinkModule) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog> |
getModule() |
Protocol |
getProtocol() |
void |
handleMessage(TelemetryProtos.TelemetryMessageLog messageLog) |
void |
init() |
public TelemetryMessageConsumer(Protocol protocol, TelemetrySinkModule sinkModule) throws Exception
Exception
@PostConstruct public void init() throws Exception
Exception
public void handleMessage(TelemetryProtos.TelemetryMessageLog messageLog)
handleMessage
in interface MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
@PreDestroy public void destroy()
public SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog> getModule()
getModule
in interface MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
public Protocol getProtocol()
Copyright © 2018. All rights reserved.