public interface InternalWorkingMemory extends WorkingMemory, InternalWorkingMemoryEntryPoint
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 |
clearNodeMemory(MemoryFactory node) |
void |
closeLiveQuery(InternalFactHandle factHandle) |
void |
deactivate() |
void |
delete(org.kie.api.runtime.rule.FactHandle factHandle,
RuleImpl rule,
Activation activation) |
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 |
executeQueuedActionsForRete() |
void |
flushPropagations() |
void |
flushPropagations(PropagationEntry propagationEntry) |
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() |
ExecutionResultImpl |
getExecutionResult() |
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() |
PropagationList |
getPropagationList() |
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.
|
PropagationEntry |
handleRestOnFireUntilHalt(DefaultAgenda.ExecutionState currentState) |
boolean |
hasPendingPropagations() |
void |
insert(InternalFactHandle handle,
Object object,
RuleImpl rule,
Activation activation,
ObjectTypeConf typeConf) |
InternalProcessRuntime |
internalGetProcessRuntime() |
boolean |
isSequential() |
void |
notifyEngineInactive() |
void |
notifyWaitOnRest() |
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(ExecutionResultImpl results) |
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.
|
PropagationEntry |
takeAllPropagations() |
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
dispose, insert
delete, delete, getEntryPointId, getFactCount, getFactHandles, getFactHandles, getObjects, getObjects, insert, retract, update, update
delete, getHandleFactory, getInternalWorkingMemory, getKnowledgeBase, getTruthMaintenanceSystem, removeFromObjectStore, reset, update
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 InternalWorkingMemoryEntryPoint
void executeQueuedActionsForRete()
void queueWorkingMemoryAction(WorkingMemoryAction action)
FactHandleFactory getFactHandleFactory()
EntryPointId getEntryPoint()
getEntryPoint
in interface InternalWorkingMemoryEntryPoint
EntryPointNode getEntryPointNode()
getEntryPointNode
in interface InternalWorkingMemoryEntryPoint
org.kie.api.runtime.rule.EntryPoint getEntryPoint(String name)
void insert(InternalFactHandle handle, Object object, RuleImpl rule, Activation activation, ObjectTypeConf typeConf)
org.kie.api.runtime.rule.FactHandle getFactHandleByIdentity(Object object)
getFactHandleByIdentity
in interface InternalWorkingMemoryEntryPoint
getFactHandleByIdentity
in interface WorkingMemory
object
- void delete(org.kie.api.runtime.rule.FactHandle factHandle, RuleImpl rule, Activation activation)
delete
in interface InternalWorkingMemoryEntryPoint
Lock getLock()
boolean isSequential()
ObjectTypeConfigurationRegistry getObjectTypeConfigurationRegistry()
getObjectTypeConfigurationRegistry
in interface InternalWorkingMemoryEntryPoint
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(ExecutionResultImpl results)
ExecutionResultImpl getExecutionResult()
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 flushPropagations(PropagationEntry propagationEntry)
void activate()
void deactivate()
boolean tryDeactivate()
void notifyEngineInactive()
boolean hasPendingPropagations()
PropagationEntry takeAllPropagations()
PropagationList getPropagationList()
Iterator<? extends PropagationEntry> getActionsIterator()
void removeGlobal(String identifier)
void notifyWaitOnRest()
PropagationEntry handleRestOnFireUntilHalt(DefaultAgenda.ExecutionState currentState)
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.