org.opennms.netmgt.alarmd.drools

Class ManagedDroolsContext

java.lang.Object

org.opennms.netmgt.alarmd.drools.ManagedDroolsContext

Direct Known Subclasses:

DroolsAlarmContext

public class ManagedDroolsContext
extends 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 and Description
static String	CLOCK_UPDATE_INTERVAL_SYS_PROP
protected AtomicLong	fireThreadId

Constructor Summary

Constructors

Constructor and Description
ManagedDroolsContext(File rulesFolder, String kbaseName, String kSessionSuffixName)

Method Summary

Modifier and Type	Method and Description
SessionClock	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()

Methods inherited from class java.lang.Object

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

Field Detail

CLOCK_UPDATE_INTERVAL_SYS_PROP

public static final String CLOCK_UPDATE_INTERVAL_SYS_PROP

See Also:

Constant Field Values

fireThreadId

protected AtomicLong fireThreadId

Constructor Detail

ManagedDroolsContext

public ManagedDroolsContext(File rulesFolder,
                            String kbaseName,
                            String kSessionSuffixName)

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 SessionClock 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()