org.opennms.features.kafka.producer.datasync

Class KafkaAlarmDataSync

java.lang.Object

org.opennms.features.kafka.producer.datasync.KafkaAlarmDataSync

All Implemented Interfaces:

Runnable, AlarmDataStore

public class KafkaAlarmDataSync
extends Object
implements AlarmDataStore, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
static String	KAFKA_STREAMS_PID

Constructor Summary

Constructors

Constructor and Description
KafkaAlarmDataSync(org.osgi.service.cm.ConfigurationAdmin configAdmin, OpennmsKafkaProducer kafkaProducer, AlarmDao alarmDao, ProtobufMapper protobufMapper, org.springframework.transaction.support.TransactionOperations transactionOperations)

Method Summary

Modifier and Type	Method and Description
void	destroy()
OpennmsModelProtos.Alarm	getAlarm(String reductionKey)
Map<String,OpennmsModelProtos.Alarm>	getAlarms()
void	init() This method initializes the stream client, but doesn't actually start it until an alarm is forwarded by the producer.
boolean	isEnabled()
boolean	isReady()
void	run()
void	setAlarmSyncIntervalMs(long intervalMs)
void	setAlarmTopic(String alarmTopic)
AlarmSyncResults	synchronizeAlarmsWithDb()

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_STREAMS_PID

public static final String KAFKA_STREAMS_PID

See Also:

Constant Field Values

Constructor Detail

KafkaAlarmDataSync

public KafkaAlarmDataSync(org.osgi.service.cm.ConfigurationAdmin configAdmin,
                          OpennmsKafkaProducer kafkaProducer,
                          AlarmDao alarmDao,
                          ProtobufMapper protobufMapper,
                          org.springframework.transaction.support.TransactionOperations transactionOperations)

Method Detail

init

public void init()
          throws IOException

This method initializes the stream client, but doesn't actually start it until an alarm is forwarded by the producer.

Throws:

IOException - when an error occurs in loading/parsing the Kafka client/stream configuration

run

public void run()

Specified by:

run in interface Runnable

destroy

public void destroy()

synchronizeAlarmsWithDb

public AlarmSyncResults synchronizeAlarmsWithDb()

Specified by:

synchronizeAlarmsWithDb in interface AlarmDataStore

setAlarmTopic

public void setAlarmTopic(String alarmTopic)

setAlarmSyncIntervalMs

public void setAlarmSyncIntervalMs(long intervalMs)

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface AlarmDataStore

isReady

public boolean isReady()

Specified by:

isReady in interface AlarmDataStore

getAlarms

public Map<String,OpennmsModelProtos.Alarm> getAlarms()

Specified by:

getAlarms in interface AlarmDataStore

getAlarm

public OpennmsModelProtos.Alarm getAlarm(String reductionKey)

Specified by:

getAlarm in interface AlarmDataStore