public class DroolsCorrelationEngine extends AbstractCorrelationEngine
DroolsCorrelationEngine class.
Constructor and Description |
---|
DroolsCorrelationEngine(String name,
com.codahale.metrics.MetricRegistry metricRegistry,
org.springframework.core.io.Resource configPath,
org.springframework.context.ApplicationContext configContext) |
Modifier and Type | Method and 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()
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() |
cancelTimer, getPendingTasksCount, getScheduler, runTimer, sendEvent, setEventIpcManager, setScheduler, setTimer
public DroolsCorrelationEngine(String name, com.codahale.metrics.MetricRegistry metricRegistry, org.springframework.core.io.Resource configPath, org.springframework.context.ApplicationContext configContext)
public org.springframework.core.io.Resource getConfigPath()
public org.springframework.context.ApplicationContext getConfigContext()
public void correlate(Event e)
correlate
correlate
in interface CorrelationEngine
correlate
in class AbstractCorrelationEngine
e
- a Event
object.protected void timerExpired(Integer timerId)
timerExpired
timerExpired
in class AbstractCorrelationEngine
timerId
- a Integer
object.public List<String> getInterestingEvents()
getInterestingEvents
getInterestingEvents
in interface CorrelationEngine
getInterestingEvents
in class AbstractCorrelationEngine
List
object.public void setInterestingEvents(List<String> ueis)
setInterestingEvents
ueis
- a List
object.public void setRulesResources(List<org.springframework.core.io.Resource> rules)
setRulesResources
rules
- a List
object.public void setGlobals(Map<String,Object> globals)
setGlobals
globals
- a Map
object.public void tearDown()
CorrelationEngine
tearDown
public Collection<? extends Object> getKieSessionObjects()
public org.kie.api.runtime.KieSession getKieSession()
public void setAssertBehaviour(String assertBehaviour)
public String getEventProcessingMode()
public void setEventProcessingMode(String eventProcessingMode)
public void setPersistState(Boolean persistState)
public Boolean getPersistState()
public void reloadConfig()
CorrelationEngine
reloadConfig
reloadConfig
in interface CorrelationEngine
reloadConfig
in class AbstractCorrelationEngine
Copyright © 2018. All rights reserved.