Package org.opennms.netmgt.correlation.drools

Class DroolsCorrelationEngine

java.lang.Object

org.opennms.netmgt.correlation.AbstractCorrelationEngine

org.opennms.netmgt.correlation.drools.DroolsCorrelationEngine

All Implemented Interfaces:

CorrelationEngine

public class DroolsCorrelationEngine
extends AbstractCorrelationEngine

DroolsCorrelationEngine class.

Version:

$Id: $

Author:

Mathew Brozowski

Field Summary

Fields

Modifier and Type	Field	Description
static String	RELOAD_STATE_AFTER_EXCEPTION

Constructor Summary

Constructors

Constructor	Description
DroolsCorrelationEngine(String name, com.codahale.metrics.MetricRegistry metricRegistry, org.springframework.core.io.Resource configPath, org.springframework.context.ApplicationContext configContext)

Method Summary

Modifier and Type	Method	Description
void	correlate(Event e)	correlate
org.springframework.context.ApplicationContext	getConfigContext()
org.springframework.core.io.Resource	getConfigPath()
String	getEventProcessingMode()
List<String>	getInterestingEvents()	getInterestingEvents
org.kie.api.runtime.KieSession	getKieSession()
Collection<? extends Object>	getKieSessionObjects()
String	getName()	getName
Boolean	getPersistState()
void	initialize()	initialize
void	reloadConfig(boolean persistState)	reloadConfig
void	setAssertBehaviour(String assertBehaviour)
void	setEventProcessingMode(String eventProcessingMode)
void	setGlobal(String name, Object value)	setGlobal
void	setGlobals(Map<String,Object> globals)	setGlobals
void	setInterestingEvents(List<String> ueis)	setInterestingEvents
void	setPersistState(Boolean persistState)
void	setRulesResources(List<org.springframework.core.io.Resource> rules)	setRulesResources
void	tearDown()	tearDown
protected void	timerExpired(Integer timerId)	timerExpired
String	toString()

Methods inherited from class org.opennms.netmgt.correlation.AbstractCorrelationEngine

cancelTimer, getPendingTasksCount, getScheduler, runTimer, sendEvent, setEventIpcManager, setScheduler, setTimer

Methods inherited from class java.lang.Object

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

Field Detail

RELOAD_STATE_AFTER_EXCEPTION

public static final String RELOAD_STATE_AFTER_EXCEPTION

See Also:

Constant Field Values

Constructor Detail

DroolsCorrelationEngine

public DroolsCorrelationEngine(String name,
                               com.codahale.metrics.MetricRegistry metricRegistry,
                               org.springframework.core.io.Resource configPath,
                               org.springframework.context.ApplicationContext configContext)

Method Detail

getConfigPath

public org.springframework.core.io.Resource getConfigPath()

getConfigContext

public org.springframework.context.ApplicationContext getConfigContext()

correlate

public void correlate(Event e)

correlate

Specified by:

correlate in interface CorrelationEngine

Specified by:

correlate in class AbstractCorrelationEngine

Parameters:

e - a Event object.

timerExpired

protected void timerExpired(Integer timerId)

timerExpired

Specified by:

timerExpired in class AbstractCorrelationEngine

Parameters:

timerId - a Integer object.

getInterestingEvents

public List<String> getInterestingEvents()

getInterestingEvents

Specified by:

getInterestingEvents in interface CorrelationEngine

Specified by:

getInterestingEvents in class AbstractCorrelationEngine

Returns:

a List object.

setInterestingEvents

public void setInterestingEvents(List<String> ueis)

setInterestingEvents

Parameters:

ueis - a List object.

setRulesResources

public void setRulesResources(List<org.springframework.core.io.Resource> rules)

setRulesResources

Parameters:

rules - a List object.

setGlobals

public void setGlobals(Map<String,Object> globals)

setGlobals

Parameters:

globals - a Map object.

initialize

public void initialize()
                throws Exception

initialize

Throws:

Exception - if any.

tearDown

public void tearDown()

Description copied from interface: CorrelationEngine

tearDown

getKieSessionObjects

public Collection<? extends Object> getKieSessionObjects()

getKieSession

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

getName

public String getName()

getName

Returns:

a String object.

setGlobal

public void setGlobal(String name,
                      Object value)

setGlobal

Parameters:

name - a String object.

value - a Object object.

setAssertBehaviour

public void setAssertBehaviour(String assertBehaviour)

getEventProcessingMode

public String getEventProcessingMode()

setEventProcessingMode

public void setEventProcessingMode(String eventProcessingMode)

setPersistState

public void setPersistState(Boolean persistState)

getPersistState

public Boolean getPersistState()

toString

public String toString()

Overrides:

toString in class Object

reloadConfig

public void reloadConfig(boolean persistState)

Description copied from interface: CorrelationEngine

reloadConfig

Specified by:

reloadConfig in interface CorrelationEngine

Specified by:

reloadConfig in class AbstractCorrelationEngine