org.opennms.plugins.dbnotifier.alarmnotifier

Class AlarmChangeNotificationClient

java.lang.Object

org.opennms.plugins.dbnotifier.alarmnotifier.AlarmChangeNotificationClient

All Implemented Interfaces:

NotificationClient

public class AlarmChangeNotificationClient
extends Object
implements NotificationClient

sends alarm change events into opennms

Author:

admin

Field Summary

Fields

Modifier and Type	Field and Description
static String	EVENT_SOURCE_NAME

Constructor Summary

Constructors

Constructor and Description
AlarmChangeNotificationClient()

Method Summary

Modifier and Type	Method and Description
void	destroy()
EventProxy	getEventProxy()
void	init()
org.json.simple.JSONObject	jsonAlarmTimeNormaliser(org.json.simple.JSONObject jsonObject) concerts all time values into a normalised time in alarm json object from database example timestamps to translate { "suppressedtime":"2016-08-04 16:11:16.01+01", "suppresseduntil":"2016-08-04 16:11:16.01+01", "lasteventtime":"2016-08-04 16:11:16.01+01", "alarmacktime":"2016-08-04 07:34:04.617+01", "firsteventtime":"2016-08-04 16:11:16.01+01", "firstautomationtime":"2016-08-04 16:12:03.272205+01", "lastautomationtime":"2016-08-04 16:12:03.272205+01" }
void	sendDbNotification(DbNotification dbNotification)
void	setEventProxy(EventProxy eventProxy)
String	timeNormaliser(String dbTimeStr) converts postgres json time format to normalised time format for matching to Elasticsearch date_optional_time or strict_date_optional_time (A generic ISO datetime parser where the date is mandatory and the time is optional see https://www.elastic.co/guide/en/elasticsearch/reference/current/mapping-date-format.html#strict-date-time)

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_SOURCE_NAME

public static final String EVENT_SOURCE_NAME

See Also:

Constant Field Values

Constructor Detail

AlarmChangeNotificationClient

public AlarmChangeNotificationClient()

Method Detail

getEventProxy

public EventProxy getEventProxy()

setEventProxy

public void setEventProxy(EventProxy eventProxy)

sendDbNotification

public void sendDbNotification(DbNotification dbNotification)

Specified by:

sendDbNotification in interface NotificationClient

jsonAlarmTimeNormaliser

public org.json.simple.JSONObject jsonAlarmTimeNormaliser(org.json.simple.JSONObject jsonObject)

concerts all time values into a normalised time in alarm json object from database example timestamps to translate { "suppressedtime":"2016-08-04 16:11:16.01+01", "suppresseduntil":"2016-08-04 16:11:16.01+01", "lasteventtime":"2016-08-04 16:11:16.01+01", "alarmacktime":"2016-08-04 07:34:04.617+01", "firsteventtime":"2016-08-04 16:11:16.01+01", "firstautomationtime":"2016-08-04 16:12:03.272205+01", "lastautomationtime":"2016-08-04 16:12:03.272205+01" }

Parameters:

jsonObject -

Returns:

timeNormaliser

public String timeNormaliser(String dbTimeStr)

converts postgres json time format to normalised time format for matching to Elasticsearch date_optional_time or strict_date_optional_time (A generic ISO datetime parser where the date is mandatory and the time is optional see https://www.elastic.co/guide/en/elasticsearch/reference/current/mapping-date-format.html#strict-date-time)

Parameters:

dbTimeStr -

Returns:

init

public void init()

Specified by:

init in interface NotificationClient

destroy

public void destroy()

Specified by:

destroy in interface NotificationClient