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

Method Summary

Modifier and Type	Method	Description
void	destroy()
Set<Adapter>	getAdapters()
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)

getAdapters

public Set<Adapter> getAdapters()