Package org.opennms.features.kafka.producer.datasync

Class KafkaAlarmDataSync

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable, AlarmDataStore

public class KafkaAlarmDataSync
extends java.lang.Object
implements AlarmDataStore, java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	KAFKA_STREAMS_PID

Constructor Summary

Constructors

Constructor	Description
KafkaAlarmDataSync(org.osgi.service.cm.ConfigurationAdmin configAdmin, OpennmsKafkaProducer kafkaProducer, ProtobufMapper protobufMapper)

Method Summary

Modifier and Type	Method	Description
void	destroy()
OpennmsModelProtos.Alarm	getAlarm(java.lang.String reductionKey)
java.util.Map<java.lang.String,OpennmsModelProtos.Alarm>	getAlarms()
AlarmSyncResults	handleAlarmSnapshot(java.util.List<OnmsAlarm> alarms)
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	setAlarmSync(boolean alarmSync)
void	setAlarmTopic(java.lang.String alarmTopic)
void	setStartWithCleanState(boolean startWithCleanState)
void	setSuppressIncrementalAlarms(boolean suppressIncrementalAlarms)

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 java.lang.String KAFKA_STREAMS_PID

See Also:

Constant Field Values

Constructor Detail

KafkaAlarmDataSync

public KafkaAlarmDataSync(org.osgi.service.cm.ConfigurationAdmin configAdmin,
                          OpennmsKafkaProducer kafkaProducer,
                          ProtobufMapper protobufMapper)

Method Detail

init

public void init()
          throws java.io.IOException

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

Specified by:

init in interface AlarmDataStore

Throws:

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

run

public void run()

Specified by:

run in interface java.lang.Runnable

destroy

public void destroy()

Specified by:

destroy in interface AlarmDataStore

handleAlarmSnapshot

public AlarmSyncResults handleAlarmSnapshot(java.util.List<OnmsAlarm> alarms)

Specified by:

handleAlarmSnapshot in interface AlarmDataStore

setAlarmTopic

public void setAlarmTopic(java.lang.String alarmTopic)

setAlarmSync

public void setAlarmSync(boolean alarmSync)

setStartWithCleanState

public void setStartWithCleanState(boolean startWithCleanState)

Specified by:

setStartWithCleanState in interface AlarmDataStore

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface AlarmDataStore

isReady

public boolean isReady()

Specified by:

isReady in interface AlarmDataStore

getAlarms

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

Specified by:

getAlarms in interface AlarmDataStore

getAlarm

public OpennmsModelProtos.Alarm getAlarm(java.lang.String reductionKey)

Specified by:

getAlarm in interface AlarmDataStore

setSuppressIncrementalAlarms

public void setSuppressIncrementalAlarms(boolean suppressIncrementalAlarms)