org.opennms.features.kafka.producer

Class OpennmsKafkaProducer

java.lang.Object

org.opennms.features.kafka.producer.OpennmsKafkaProducer

All Implemented Interfaces:

AlarmLifecycleListener, EventListener

public class OpennmsKafkaProducer
extends Object
implements AlarmLifecycleListener, EventListener

Field Summary

Fields

Modifier and Type	Field and Description
static String	KAFKA_CLIENT_PID

Constructor Summary

Constructors

Constructor and Description
OpennmsKafkaProducer(ProtobufMapper protobufMapper, NodeCache nodeCache, org.osgi.service.cm.ConfigurationAdmin configAdmin, EventSubscriptionService eventSubscriptionService)

Method Summary

Modifier and Type	Method and Description
void	destroy()
CountDownLatch	getAlarmForwardedLatch()
CountDownLatch	getEventForwardedLatch()
String	getName() Return the id of the listener
CountDownLatch	getNodeForwardedLatch()
void	handleAlarmSnapshot(List<OnmsAlarm> alarms)
void	handleDeletedAlarm(int alarmId, String reductionKey)
void	handleDeletedAlarm(String reductionKey)
void	handleNewOrUpdatedAlarm(OnmsAlarm alarm)
void	init()
boolean	isForwardingAlarms()
void	onEvent(Event event) Process a sent event.
void	setAlarmFilter(String alarmFilter)
void	setAlarmTopic(String alarmTopic)
OpennmsKafkaProducer	setDataSync(KafkaAlarmDataSync dataSync)
void	setEventFilter(String eventFilter)
void	setEventTopic(String eventTopic)
void	setKafkaSendQueueCapacity(int kafkaSendQueueCapacity)
void	setNodeTopic(String nodeTopic)
void	setSuppressIncrementalAlarms(boolean suppressIncrementalAlarms)
boolean	shouldForwardAlarm(OnmsAlarm alarm)

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_CLIENT_PID

public static final String KAFKA_CLIENT_PID

See Also:

Constant Field Values

Constructor Detail

OpennmsKafkaProducer

public OpennmsKafkaProducer(ProtobufMapper protobufMapper,
                            NodeCache nodeCache,
                            org.osgi.service.cm.ConfigurationAdmin configAdmin,
                            EventSubscriptionService eventSubscriptionService)

Method Detail

init

public void init()
          throws IOException

Throws:

IOException

destroy

public void destroy()

shouldForwardAlarm

public boolean shouldForwardAlarm(OnmsAlarm alarm)

handleAlarmSnapshot

public void handleAlarmSnapshot(List<OnmsAlarm> alarms)

Specified by:

handleAlarmSnapshot in interface AlarmLifecycleListener

handleNewOrUpdatedAlarm

public void handleNewOrUpdatedAlarm(OnmsAlarm alarm)

Specified by:

handleNewOrUpdatedAlarm in interface AlarmLifecycleListener

handleDeletedAlarm

public void handleDeletedAlarm(int alarmId,
                               String reductionKey)

Specified by:

handleDeletedAlarm in interface AlarmLifecycleListener

handleDeletedAlarm

public void handleDeletedAlarm(String reductionKey)

getName

public String getName()

Description copied from interface: EventListener

Return the id of the listener

Specified by:

getName in interface EventListener

Returns:

a String object.

onEvent

public void onEvent(Event event)

Description copied from interface: EventListener

Process a sent event.

Specified by:

onEvent in interface EventListener

Parameters:

event - a Event object.

setEventTopic

public void setEventTopic(String eventTopic)

setAlarmTopic

public void setAlarmTopic(String alarmTopic)

setNodeTopic

public void setNodeTopic(String nodeTopic)

setEventFilter

public void setEventFilter(String eventFilter)

setAlarmFilter

public void setAlarmFilter(String alarmFilter)

setDataSync

public OpennmsKafkaProducer setDataSync(KafkaAlarmDataSync dataSync)

isForwardingAlarms

public boolean isForwardingAlarms()

getEventForwardedLatch

public CountDownLatch getEventForwardedLatch()

getAlarmForwardedLatch

public CountDownLatch getAlarmForwardedLatch()

getNodeForwardedLatch

public CountDownLatch getNodeForwardedLatch()

setSuppressIncrementalAlarms

public void setSuppressIncrementalAlarms(boolean suppressIncrementalAlarms)

setKafkaSendQueueCapacity

public void setKafkaSendQueueCapacity(int kafkaSendQueueCapacity)