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 protocolDef, List<Adapter> adapterDef, TelemetrySinkModule sinkModule)
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()
void	setAdapterRegistry(TelemetryAdapterRegistry adapterRegistry)

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

TelemetryMessageConsumer

public TelemetryMessageConsumer(Protocol protocolDef,
                                List<Adapter> adapterDef,
                                TelemetrySinkModule sinkModule)

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()

setAdapterRegistry

public void setAdapterRegistry(TelemetryAdapterRegistry adapterRegistry)