public interface InternalWorkingMemory extends WorkingMemory, WorkingMemoryEntryPoint, EventSupport
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
activationFired()
This method is called by the agenda right after an activation was fired
to allow the working memory to resume any activities blocked during
activation firing.
|
void |
addPropagation(PropagationEntry propagationEntry) |
void |
cancelActivation(Activation activation,
boolean declarativeAgenda) |
void |
clearNodeMemory(MemoryFactory node) |
void |
closeLiveQuery(InternalFactHandle factHandle) |
void |
deactivate() |
void |
endBatchExecution() |
void |
endOperation()
This method must be called after finishing any work in the engine,
like inserting a new fact or firing a new rule.
|
void |
flushPropagations() |
Iterator<? extends PropagationEntry> |
getActionsIterator() |
InternalAgenda |
getAgenda()
Returns the Agenda for this WorkingMemory.
|
org.kie.api.runtime.Calendars |
getCalendars() |
Map<String,org.kie.api.runtime.Channel> |
getChannels()
Returns a map of channel Id->Channel of all channels in
this working memory
|
EntryPointId |
getEntryPoint() |
org.kie.api.runtime.rule.EntryPoint |
getEntryPoint(String name) |
EntryPointNode |
getEntryPointNode() |
Collection<? extends org.kie.api.runtime.rule.EntryPoint> |
getEntryPoints() |
org.kie.api.runtime.rule.FactHandle |
getFactHandleByIdentity(Object object)
Looks for the fact handle associated to the given object
by looking up the object IDENTITY (==), even if rule base
is configured to AssertBehavior.EQUALITY.
|
FactHandleFactory |
getFactHandleFactory() |
long |
getIdentifier() |
long |
getIdleTime()
Returns the number of time units (usually ms) that the engine is idle
according to the session clock or -1 if it is not idle.
|
InternalFactHandle |
getInitialFactHandle() |
InternalKnowledgeRuntime |
getKnowledgeRuntime() |
Lock |
getLock() |
long |
getNextPropagationIdCounter() |
NodeMemories |
getNodeMemories() |
<T extends Memory> |
getNodeMemory(MemoryFactory<T> node) |
ObjectStore |
getObjectStore() |
ObjectTypeConfigurationRegistry |
getObjectTypeConfigurationRegistry() |
InternalProcessRuntime |
getProcessRuntime() |
default PropagationList |
getPropagationList() |
default InternalRuleUnitExecutor |
getRuleUnitExecutor() |
SessionConfiguration |
getSessionConfiguration() |
TimerService |
getTimerService()
Returns the TimerService instance (session clock) for this
session.
|
long |
getTimeToNextJob()
Returns the number of time units (usually ms) to
the next scheduled job
|
long |
getTotalFactCount()
Returns the total number of facts in the working memory, i.e., counting
all facts from all entry points.
|
InternalProcessRuntime |
internalGetProcessRuntime() |
boolean |
isSequential() |
void |
notifyWaitOnRest() |
default void |
onResume() |
default void |
onSuspend() |
void |
prepareToFireActivation()
This method is called by the agenda before firing a new activation
to ensure the working memory is in a safe state to fire the activation.
|
void |
queueWorkingMemoryAction(WorkingMemoryAction action) |
void |
removeGlobal(String identifier) |
void |
setAgendaEventSupport(AgendaEventSupport agendaEventSupport) |
void |
setIdentifier(long id) |
void |
setRuleRuntimeEventSupport(RuleRuntimeEventSupport workingMemoryEventSupport) |
void |
startBatchExecution() |
void |
startOperation()
This method must be called before starting any new work in the engine,
like inserting a new fact or firing a new rule.
|
boolean |
tryDeactivate() |
void |
updateEntryPointsCache() |
clearActivationGroup, clearAgenda, clearAgendaGroup, clearRuleFlowGroup, fireAllRules, fireAllRules, fireAllRules, fireAllRules, getEnvironment, getFactHandle, getGlobal, getGlobalResolver, getKnowledgeBase, getObject, getProcessInstance, getProcessInstance, getProcessInstances, getQueryResults, getSessionClock, getWorkingMemoryEntryPoint, getWorkItemManager, halt, iterateFactHandles, iterateFactHandles, iterateObjects, iterateObjects, setAsyncExceptionHandler, setFocus, setGlobal, setGlobalResolver, startProcess, startProcess
addEventListener, addEventListener, getAgendaEventListeners, getRuleRuntimeEventListeners, removeEventListener, removeEventListener
addEventListener, getKieBaseEventListeners, removeEventListener
delete, delete, dispose, getHandleFactory, getInternalWorkingMemory, getTruthMaintenanceSystem, insert, reset, update
delete, delete, getEntryPointId, getFactCount, getFactHandles, getFactHandles, getObjects, getObjects, insert, retract, update, update
getAgendaEventListeners, getAgendaEventSupport, getRuleEventSupport, getRuleRuntimeEventListeners, getRuleRuntimeEventSupport
InternalAgenda getAgenda()
WorkingMemory
getAgenda
in interface WorkingMemory
long getIdentifier()
void setIdentifier(long id)
void setRuleRuntimeEventSupport(RuleRuntimeEventSupport workingMemoryEventSupport)
void setAgendaEventSupport(AgendaEventSupport agendaEventSupport)
<T extends Memory> T getNodeMemory(MemoryFactory<T> node)
void clearNodeMemory(MemoryFactory node)
NodeMemories getNodeMemories()
long getNextPropagationIdCounter()
ObjectStore getObjectStore()
getObjectStore
in interface WorkingMemoryEntryPoint
void queueWorkingMemoryAction(WorkingMemoryAction action)
FactHandleFactory getFactHandleFactory()
EntryPointId getEntryPoint()
getEntryPoint
in interface WorkingMemoryEntryPoint
EntryPointNode getEntryPointNode()
getEntryPointNode
in interface WorkingMemoryEntryPoint
org.kie.api.runtime.rule.EntryPoint getEntryPoint(String name)
org.kie.api.runtime.rule.FactHandle getFactHandleByIdentity(Object object)
getFactHandleByIdentity
in interface WorkingMemory
getFactHandleByIdentity
in interface WorkingMemoryEntryPoint
object
- Lock getLock()
boolean isSequential()
ObjectTypeConfigurationRegistry getObjectTypeConfigurationRegistry()
getObjectTypeConfigurationRegistry
in interface WorkingMemoryEntryPoint
InternalFactHandle getInitialFactHandle()
org.kie.api.runtime.Calendars getCalendars()
TimerService getTimerService()
InternalKnowledgeRuntime getKnowledgeRuntime()
Map<String,org.kie.api.runtime.Channel> getChannels()
Collection<? extends org.kie.api.runtime.rule.EntryPoint> getEntryPoints()
SessionConfiguration getSessionConfiguration()
void startBatchExecution()
void endBatchExecution()
void startOperation()
void endOperation()
long getIdleTime()
long getTimeToNextJob()
void updateEntryPointsCache()
void prepareToFireActivation()
void activationFired()
long getTotalFactCount()
InternalProcessRuntime getProcessRuntime()
InternalProcessRuntime internalGetProcessRuntime()
void closeLiveQuery(InternalFactHandle factHandle)
void addPropagation(PropagationEntry propagationEntry)
void flushPropagations()
void activate()
void deactivate()
boolean tryDeactivate()
Iterator<? extends PropagationEntry> getActionsIterator()
void removeGlobal(String identifier)
void notifyWaitOnRest()
void cancelActivation(Activation activation, boolean declarativeAgenda)
default PropagationList getPropagationList()
default void onSuspend()
default void onResume()
default InternalRuleUnitExecutor getRuleUnitExecutor()
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.