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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
correlate(Event e)
correlateorg.springframework.context.ApplicationContext
getConfigContext()
org.springframework.core.io.Resource
getConfigPath()
String
getEventProcessingMode()
List<String>
getInterestingEvents()
getInterestingEventsorg.kie.api.runtime.KieSession
getKieSession()
Collection<? extends Object>
getKieSessionObjects()
String
getName()
getNameBoolean
getPersistState()
void
initialize()
initializevoid
reloadConfig(boolean persistState)
reloadConfigvoid
setAssertBehaviour(String assertBehaviour)
void
setEventProcessingMode(String eventProcessingMode)
void
setGlobal(String name, Object value)
setGlobalvoid
setGlobals(Map<String,Object> globals)
setGlobalsvoid
setInterestingEvents(List<String> ueis)
setInterestingEventsvoid
setPersistState(Boolean persistState)
void
setRulesResources(List<org.springframework.core.io.Resource> rules)
setRulesResourcesvoid
tearDown()
tearDownprotected void
timerExpired(Integer timerId)
timerExpiredString
toString()
-
Methods inherited from class org.opennms.netmgt.correlation.AbstractCorrelationEngine
cancelTimer, getPendingTasksCount, getScheduler, runTimer, sendEvent, setEventIpcManager, setScheduler, setTimer
-
-
-
-
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 interfaceCorrelationEngine
- Specified by:
correlate
in classAbstractCorrelationEngine
- Parameters:
e
- aEvent
object.
-
timerExpired
protected void timerExpired(Integer timerId)
timerExpired
- Specified by:
timerExpired
in classAbstractCorrelationEngine
- Parameters:
timerId
- aInteger
object.
-
getInterestingEvents
public List<String> getInterestingEvents()
getInterestingEvents
- Specified by:
getInterestingEvents
in interfaceCorrelationEngine
- Specified by:
getInterestingEvents
in classAbstractCorrelationEngine
- Returns:
- a
List
object.
-
setInterestingEvents
public void setInterestingEvents(List<String> ueis)
setInterestingEvents
- Parameters:
ueis
- aList
object.
-
setRulesResources
public void setRulesResources(List<org.springframework.core.io.Resource> rules)
setRulesResources
- Parameters:
rules
- aList
object.
-
setGlobals
public void setGlobals(Map<String,Object> globals)
setGlobals
- Parameters:
globals
- aMap
object.
-
tearDown
public void tearDown()
Description copied from interface:CorrelationEngine
tearDown
-
getKieSessionObjects
public Collection<? extends Object> getKieSessionObjects()
-
getKieSession
public org.kie.api.runtime.KieSession getKieSession()
-
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()
-
reloadConfig
public void reloadConfig(boolean persistState)
Description copied from interface:CorrelationEngine
reloadConfig
- Specified by:
reloadConfig
in interfaceCorrelationEngine
- Specified by:
reloadConfig
in classAbstractCorrelationEngine
-
-