org.opennms.netmgt.telemetry.daemon

Class TelemetryMessageConsumer

java.lang.Object

org.opennms.netmgt.telemetry.daemon.TelemetryMessageConsumer

All Implemented Interfaces:

MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>

public class TelemetryMessageConsumer
extends Object
implements MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>

Constructor Summary

Constructors

Constructor and Description
TelemetryMessageConsumer(Protocol protocol, TelemetrySinkModule sinkModule)

Method Summary

Modifier and Type	Method and Description
void	destroy()
SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>	getModule()
Protocol	getProtocol()
void	handleMessage(TelemetryProtos.TelemetryMessageLog messageLog)
void	init()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TelemetryMessageConsumer

public TelemetryMessageConsumer(Protocol protocol,
                                TelemetrySinkModule sinkModule)
                         throws Exception

Throws:

Exception

Method Detail

init

@PostConstruct
public void init()
                         throws Exception

Throws:

Exception

handleMessage

public void handleMessage(TelemetryProtos.TelemetryMessageLog messageLog)

Specified by:

handleMessage in interface MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>

destroy

@PreDestroy
public void destroy()

getModule

public SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog> getModule()

Specified by:

getModule in interface MessageConsumer<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>

getProtocol

public Protocol getProtocol()