Package org.opennms.netmgt.alarmd.northbounder.drools

Class DroolsNorthbounder

java.lang.Object

org.opennms.netmgt.alarmd.api.support.AbstractNorthbounder

org.opennms.netmgt.alarmd.northbounder.drools.DroolsNorthbounder

All Implemented Interfaces:

java.lang.Runnable, Northbounder, StatusFactory<NorthboundAlarm>, org.springframework.beans.factory.InitializingBean

public class DroolsNorthbounder
extends AbstractNorthbounder
implements org.springframework.beans.factory.InitializingBean

Process alarms via Drools.

Author:

Alejandro Galue

Field Summary

Fields

Modifier and Type	Field	Description
protected static java.lang.String	NBI_NAME	The Constant NBI_NAME.

Constructor Summary

Constructors

Constructor	Description
DroolsNorthbounder(org.springframework.context.ApplicationContext context, DroolsNorthbounderConfigDao configDao, EventProxy eventProxy, java.lang.String engineName)	Instantiates a new Drools northbounder.

Method Summary

Modifier and Type	Method	Description
boolean	accepts(NorthboundAlarm alarm)	The abstraction makes a call here to determine if the alarm should be placed on the queue of alarms to be sent northerly.
void	afterPropertiesSet()
void	forwardAlarms(java.util.List<NorthboundAlarm> alarms)	Each implementation of the AbstractNorthbounder has a nice queue (Nagle's algorithmic) and the worker thread that processes the queue calls this method to send alarms to the northern NMS.
protected DroolsNorthbounderConfig	getConfig()	Gets the configuration.
org.kie.api.runtime.KieSession	getKieSession()	Gets the kie session.
java.util.Collection<? extends java.lang.Object>	getKieSessionObjects()	Gets the kie session objects.
boolean	isReady()	Used to determine if the northbounder is ready to accept alarms.
protected void	onStop()	Override this to perform actions when stopping.
void	sendEvent(Event event)	Send event.

Methods inherited from class org.opennms.netmgt.alarmd.api.support.AbstractNorthbounder

createMapping, createSyncLostMessage, discard, getName, onAlarm, onPostStart, onPreStart, preserve, reloadConfig, run, setMaxBatchSize, setMaxPreservedAlarms, setNaglesDelay, setRetryInterval, start, stop

Methods inherited from class java.lang.Object

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

Field Detail

NBI_NAME

protected static final java.lang.String NBI_NAME

The Constant NBI_NAME.

See Also:

Constant Field Values

Constructor Detail

DroolsNorthbounder

public DroolsNorthbounder(org.springframework.context.ApplicationContext context,
                          DroolsNorthbounderConfigDao configDao,
                          EventProxy eventProxy,
                          java.lang.String engineName)

Instantiates a new Drools northbounder.

Parameters:

configDao - the configuration DAO

engineName - the engine name

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

onStop

protected void onStop()

Description copied from class: AbstractNorthbounder

Override this to perform actions when stopping.

Overrides:

onStop in class AbstractNorthbounder

accepts

public boolean accepts(NorthboundAlarm alarm)

The abstraction makes a call here to determine if the alarm should be placed on the queue of alarms to be sent northerly.

Specified by:

accepts in class AbstractNorthbounder

Parameters:

alarm - the alarm

Returns:

true, if successful

forwardAlarms

public void forwardAlarms(java.util.List<NorthboundAlarm> alarms)
                   throws NorthbounderException

Each implementation of the AbstractNorthbounder has a nice queue (Nagle's algorithmic) and the worker thread that processes the queue calls this method to send alarms to the northern NMS.

Specified by:

forwardAlarms in class AbstractNorthbounder

Parameters:

alarms - the alarms

Throws:

NorthbounderException - the northbounder exception

getKieSessionObjects

public java.util.Collection<? extends java.lang.Object> getKieSessionObjects()

Gets the kie session objects.

Returns:

the kie session objects

getKieSession

public org.kie.api.runtime.KieSession getKieSession()

Gets the kie session.

Returns:

the kie session

sendEvent

public void sendEvent(Event event)

Send event.

Parameters:

event - the event

getConfig

protected DroolsNorthbounderConfig getConfig()

Gets the configuration.

Returns:

the configuration

isReady

public boolean isReady()

Description copied from interface: Northbounder

Used to determine if the northbounder is ready to accept alarms. If no northbounders are ready, the caller can save resources by not creating and initializing the NorthboundAlarms. This method is called once after northbounder is registered and started. If the status were to change sometime after, the northbounder must re-register itself.

Specified by:

isReady in interface Northbounder

Returns:

true if the northbounder is ready to accept alarms, false otherwise.