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(QueueConfig queueConfig, TelemetrySinkModule sinkModule)
TelemetryMessageConsumer(QueueDefinition queueDef, Collection<? extends AdapterDefinition> adapterDefs, TelemetrySinkModule sinkModule)

Method Summary

Modifier and Type	Method and Description
void	destroy()
SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>	getModule()
QueueDefinition	getQueue()
void	handleMessage(TelemetryProtos.TelemetryMessageLog messageLog)
void	init()
void	setRegistry(TelemetryRegistry telemetryRegistry)

Methods inherited from class java.lang.Object

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

Constructor Detail

TelemetryMessageConsumer

public TelemetryMessageConsumer(QueueConfig queueConfig,
                                TelemetrySinkModule sinkModule)
                         throws Exception

Throws:

Exception

TelemetryMessageConsumer

public TelemetryMessageConsumer(QueueDefinition queueDef,
                                Collection<? extends AdapterDefinition> adapterDefs,
                                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>

getQueue

public QueueDefinition getQueue()

setRegistry

public void setRegistry(TelemetryRegistry telemetryRegistry)