Package org.opennms.netmgt.alarmd.drools
Class ManagedDroolsContext
- java.lang.Object
-
- org.opennms.netmgt.alarmd.drools.ManagedDroolsContext
-
- Direct Known Subclasses:
DroolsAlarmContext
public class ManagedDroolsContext extends java.lang.Object
This class focuses on providing a Drools context which loads a set of rules from the filesystem and can be dynamically reloaded. It should not have knowledge of the underlying rules or facts that are inserted in the context.- Author:
- jwhite
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.concurrent.atomic.AtomicLong
fireThreadId
-
Constructor Summary
Constructors Constructor Description ManagedDroolsContext(java.io.File rulesFolder, java.lang.String kbaseName, java.lang.String kSessionSuffixName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.kie.api.time.SessionPseudoClock
getClock()
org.kie.api.runtime.KieSession
getKieSession()
com.codahale.metrics.MetricRegistry
getMetrics()
boolean
isStarted()
boolean
isUsePseudoClock()
void
onStart()
void
reload()
void
setOnNewKiewSessionCallback(java.util.function.Consumer<org.kie.api.runtime.KieSession> onNewKiewSessionCallback)
void
setUseManualTick(boolean useManualTick)
void
setUsePseudoClock(boolean usePseudoClock)
void
start()
void
stop()
void
tick()
-
-
-
Method Detail
-
start
public void start()
-
onStart
public void onStart()
-
reload
public void reload()
-
tick
public void tick()
-
stop
public void stop()
-
getMetrics
public com.codahale.metrics.MetricRegistry getMetrics()
-
isStarted
public boolean isStarted()
-
getClock
public org.kie.api.time.SessionPseudoClock getClock()
-
isUsePseudoClock
public boolean isUsePseudoClock()
-
setUsePseudoClock
public void setUsePseudoClock(boolean usePseudoClock)
-
setUseManualTick
public void setUseManualTick(boolean useManualTick)
-
setOnNewKiewSessionCallback
public void setOnNewKiewSessionCallback(java.util.function.Consumer<org.kie.api.runtime.KieSession> onNewKiewSessionCallback)
-
getKieSession
public org.kie.api.runtime.KieSession getKieSession()
-
-