org.opennms.netmgt.telemetry.daemon

Class TelemetryMessageConsumer

java.lang.Object

org.opennms.netmgt.telemetry.daemon.TelemetryMessageConsumer

All Implemented Interfaces:

MessageConsumer<TelemetryMessage,TelemetryMessageLogDTO>

public class TelemetryMessageConsumer
extends Object
implements MessageConsumer<TelemetryMessage,TelemetryMessageLogDTO>

Constructor Summary

Constructors

Constructor and Description
TelemetryMessageConsumer(Protocol protocol, TelemetrySinkModule sinkModule)

Method Summary

Modifier and Type	Method and Description
SinkModule<TelemetryMessage,TelemetryMessageLogDTO>	getModule()
Protocol	getProtocol()
void	handleMessage(TelemetryMessageLogDTO 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(TelemetryMessageLogDTO messageLog)

Specified by:

handleMessage in interface MessageConsumer<TelemetryMessage,TelemetryMessageLogDTO>

getModule

public SinkModule<TelemetryMessage,TelemetryMessageLogDTO> getModule()

Specified by:

getModule in interface MessageConsumer<TelemetryMessage,TelemetryMessageLogDTO>

getProtocol

public Protocol getProtocol()