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 java.lang.String
RELOAD_STATE_AFTER_EXCEPTION
-
Constructor Summary
Constructors Constructor Description DroolsCorrelationEngine(java.lang.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()
java.lang.String
getEventProcessingMode()
java.util.List<java.lang.String>
getInterestingEvents()
getInterestingEventsorg.kie.api.runtime.KieSession
getKieSession()
java.util.Collection<? extends java.lang.Object>
getKieSessionObjects()
java.lang.String
getName()
getNamejava.lang.Boolean
getPersistState()
void
initialize()
initializevoid
reloadConfig(boolean persistState)
reloadConfigvoid
setAssertBehaviour(java.lang.String assertBehaviour)
void
setEventProcessingMode(java.lang.String eventProcessingMode)
void
setGlobal(java.lang.String name, java.lang.Object value)
setGlobalvoid
setGlobals(java.util.Map<java.lang.String,java.lang.Object> globals)
setGlobalsvoid
setInterestingEvents(java.util.List<java.lang.String> ueis)
setInterestingEventsvoid
setPersistState(java.lang.Boolean persistState)
void
setRulesResources(java.util.List<org.springframework.core.io.Resource> rules)
setRulesResourcesvoid
tearDown()
tearDownprotected void
timerExpired(java.lang.Integer timerId)
timerExpiredjava.lang.String
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 java.lang.String RELOAD_STATE_AFTER_EXCEPTION
- See Also:
- Constant Field Values
-
-
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(java.lang.Integer timerId)
timerExpired
- Specified by:
timerExpired
in classAbstractCorrelationEngine
- Parameters:
timerId
- aInteger
object.
-
getInterestingEvents
public java.util.List<java.lang.String> getInterestingEvents()
getInterestingEvents
- Specified by:
getInterestingEvents
in interfaceCorrelationEngine
- Specified by:
getInterestingEvents
in classAbstractCorrelationEngine
- Returns:
- a
List
object.
-
setInterestingEvents
public void setInterestingEvents(java.util.List<java.lang.String> ueis)
setInterestingEvents
- Parameters:
ueis
- aList
object.
-
setRulesResources
public void setRulesResources(java.util.List<org.springframework.core.io.Resource> rules)
setRulesResources
- Parameters:
rules
- aList
object.
-
setGlobals
public void setGlobals(java.util.Map<java.lang.String,java.lang.Object> globals)
setGlobals
- Parameters:
globals
- aMap
object.
-
initialize
public void initialize() throws java.lang.Exception
initialize
- Throws:
java.lang.Exception
- if any.
-
tearDown
public void tearDown()
Description copied from interface:CorrelationEngine
tearDown
-
getKieSessionObjects
public java.util.Collection<? extends java.lang.Object> getKieSessionObjects()
-
getKieSession
public org.kie.api.runtime.KieSession getKieSession()
-
getName
public java.lang.String getName()
getName
- Returns:
- a
String
object.
-
setGlobal
public void setGlobal(java.lang.String name, java.lang.Object value)
setGlobal
- Parameters:
name
- aString
object.value
- aObject
object.
-
setAssertBehaviour
public void setAssertBehaviour(java.lang.String assertBehaviour)
-
getEventProcessingMode
public java.lang.String getEventProcessingMode()
-
setEventProcessingMode
public void setEventProcessingMode(java.lang.String eventProcessingMode)
-
setPersistState
public void setPersistState(java.lang.Boolean persistState)
-
getPersistState
public java.lang.Boolean getPersistState()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
reloadConfig
public void reloadConfig(boolean persistState)
Description copied from interface:CorrelationEngine
reloadConfig
- Specified by:
reloadConfig
in interfaceCorrelationEngine
- Specified by:
reloadConfig
in classAbstractCorrelationEngine
-
-