|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.drools.common.AbstractWorkingMemory
public abstract class AbstractWorkingMemory
Implementation of WorkingMemory
.
Nested Class Summary | |
---|---|
static class |
AbstractWorkingMemory.GlobalsAdapter
|
class |
AbstractWorkingMemory.RuleFlowDeactivateEvent
|
Constructor Summary | |
---|---|
AbstractWorkingMemory()
|
|
AbstractWorkingMemory(int id,
InternalRuleBase ruleBase,
FactHandleFactory handleFactory,
InternalFactHandle initialFactHandle,
long propagationContext,
SessionConfiguration config,
org.drools.runtime.Environment environment)
|
|
AbstractWorkingMemory(int id,
InternalRuleBase ruleBase,
FactHandleFactory handleFactory,
InternalFactHandle initialFactHandle,
long propagationContext,
SessionConfiguration config,
org.drools.runtime.Environment environment,
WorkingMemoryEventSupport workingMemoryEventSupport,
AgendaEventSupport agendaEventSupport)
|
|
AbstractWorkingMemory(int id,
InternalRuleBase ruleBase,
FactHandleFactory handleFactory,
SessionConfiguration config,
org.drools.runtime.Environment environment)
Construct. |
|
AbstractWorkingMemory(int id,
InternalRuleBase ruleBase,
FactHandleFactory handleFactory,
SessionConfiguration config,
org.drools.runtime.Environment environment,
WorkingMemoryEventSupport workingMemoryEventSupport,
AgendaEventSupport agendaEventSupport)
|
Method Summary | |
---|---|
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 |
addEventListener(AgendaEventListener listener)
Add an event listener. |
void |
addEventListener(org.drools.event.process.ProcessEventListener listener)
|
void |
addEventListener(RuleBaseEventListener listener)
Add an event listener. |
void |
addEventListener(WorkingMemoryEventListener listener)
Add an event listener. |
void |
addLIANodePropagation(LIANodePropagation liaNodePropagation)
|
void |
clearActivationGroup(String group)
Clears the Activation Group, cancellings all its Activations |
void |
clearAgenda()
Clear the Agenda. |
void |
clearAgendaGroup(String group)
Clear the Agenda Group, cancelling all its Activations. |
void |
clearNodeMemory(NodeMemory node)
|
void |
clearRuleFlowGroup(String group)
Clears the RuleFlow group, cancelling all its Activations |
org.drools.runtime.process.ProcessInstance |
createProcessInstance(String processId,
Map<String,Object> parameters)
|
void |
dispose()
Internal method called by the engine when the session is being disposed, so that the entry point can proceed with the necessary clean ups. |
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 |
executeQueuedActions()
|
int |
fireAllRules()
Fire all items on the agenda until empty. |
int |
fireAllRules(AgendaFilter agendaFilter)
Fire all items on the agenda until empty, using the given AgendaFiler |
int |
fireAllRules(AgendaFilter agendaFilter,
int fireLimit)
Fire all items on the agenda using the given AgendaFiler until empty or at most 'fireLimit' rules have fired |
int |
fireAllRules(int fireLimit)
Fire all items on the agenda until empty or at most 'fireLimit' rules have fired |
void |
fireUntilHalt()
Keeps firing activations until a halt is called. |
void |
fireUntilHalt(AgendaFilter agendaFilter)
Keeps firing activations until a halt is called. |
Queue<WorkingMemoryAction> |
getActionQueue()
|
Map |
getActivationParameters(Activation activation)
Helper method |
Map.Entry[] |
getActivationParameters(long activationId)
|
Agenda |
getAgenda()
Returns the Agenda for this WorkingMemory. |
List |
getAgendaEventListeners()
Returns all event listeners. |
AgendaEventSupport |
getAgendaEventSupport()
|
org.drools.runtime.Calendars |
getCalendars()
|
Map<String,org.drools.runtime.Channel> |
getChannels()
Returns a map of channel Id->Channel of all channels in this working memory |
DateFormats |
getDateFormats()
|
String |
getEntryPointId()
|
EntryPointNode |
getEntryPointNode()
|
Map<String,WorkingMemoryEntryPoint> |
getEntryPoints()
|
org.drools.runtime.Environment |
getEnvironment()
|
ExecutionResultImpl |
getExecutionResult()
|
Map<String,org.drools.runtime.ExitPoint> |
getExitPoints()
Deprecated. Use getChannels() instead. |
long |
getFactCount()
|
FactHandle |
getFactHandle(Object object)
Retrieve the FactHandle associated with an Object. |
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()
|
Object |
getGlobal(String identifier)
Retrieve a specific instance of global data by identifier |
GlobalResolver |
getGlobalResolver()
Returns the current GlobalResolver |
int |
getId()
|
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()
|
long |
getLastIdleTimestamp()
|
Lock |
getLock()
|
long |
getNextPropagationIdCounter()
|
NodeMemories |
getNodeMemories()
|
Memory |
getNodeMemory(NodeMemory node)
Retrieve the JoinMemory for a particular
JoinNode . |
Object |
getObject(org.drools.runtime.rule.FactHandle handle)
Returns the fact Object for the given FactHandle . |
org.drools.marshalling.ObjectMarshallingStrategyStore |
getObjectMarshallingStrategyStore()
|
ObjectStore |
getObjectStore()
|
ObjectTypeConfigurationRegistry |
getObjectTypeConfigurationRegistry()
|
PartitionTaskManager |
getPartitionTaskManager(RuleBasePartitionId partitionId)
Returns the PartitionTaskManager for the given partition ID in case the rulebase has partitions enabled |
Collection<org.drools.event.process.ProcessEventListener> |
getProcessEventListeners()
|
org.drools.runtime.process.ProcessInstance |
getProcessInstance(long processInstanceId)
Returns the process instance with the given id. |
Collection<org.drools.runtime.process.ProcessInstance> |
getProcessInstances()
Returns the list of process instances of this working memory. |
InternalProcessRuntime |
getProcessRuntime()
|
long |
getPropagationIdCounter()
|
abstract QueryResults |
getQueryResults(String query)
|
RuleBase |
getRuleBase()
Retrieve the RuleBase for this working memory. |
List |
getRuleBaseEventListeners()
Returns all event listeners. |
org.drools.time.SessionClock |
getSessionClock()
Returns the session clock instance associated with this session |
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. |
TruthMaintenanceSystem |
getTruthMaintenanceSystem()
|
WorkingMemoryEntryPoint |
getWorkingMemoryEntryPoint(String name)
Returns the interface instance for a given entry point, so that the application can manage entry-point-scoped facts. |
Collection<WorkingMemoryEntryPoint> |
getWorkingMemoryEntryPoints()
|
List |
getWorkingMemoryEventListeners()
Returns all event listeners. |
WorkingMemoryEventSupport |
getWorkingMemoryEventSupport()
|
org.drools.runtime.process.WorkItemManager |
getWorkItemManager()
|
void |
halt()
Stops rule firing after the current rule finishes executing |
void |
insert(InternalFactHandle handle,
Object object,
Rule rule,
Activation activation,
ObjectTypeConf typeConf)
|
FactHandle |
insert(Object object)
Assert a fact. |
FactHandle |
insert(Object object,
boolean dynamic)
Insert a fact registering JavaBean PropertyChangeListeners
on the Object to automatically trigger update calls
if dynamic is true . |
FactHandle |
insert(Object object,
boolean dynamic,
boolean logical,
Rule rule,
Activation activation)
|
FactHandle |
insertLogical(Object object)
|
FactHandle |
insertLogical(Object object,
boolean dynamic)
|
boolean |
isPartitionManagersActive()
|
boolean |
isSequential()
|
Iterator |
iterateFactHandles()
This class is not thread safe, changes to the working memory during iteration may give unexpected results |
Iterator |
iterateFactHandles(org.drools.runtime.ObjectFilter filter)
This class is not thread safe, changes to the working memory during iteration may give unexpected results |
List |
iterateNonDefaultEntryPointObjectsToList()
|
Iterator |
iterateObjects()
This class is not thread safe, changes to the working memory during iteration may give unexpected results |
Iterator |
iterateObjects(org.drools.runtime.ObjectFilter filter)
This class is not thread safe, changes to the working memory during iteration may give unexpected results |
List |
iterateObjectsToList()
|
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 |
registerChannel(String name,
org.drools.runtime.Channel channel)
|
void |
registerExitPoint(String name,
org.drools.runtime.ExitPoint exitPoint)
Deprecated. Use registerChannel(String, Channel) instead. |
void |
removeEventListener(AgendaEventListener listener)
Remove an event listener. |
void |
removeEventListener(org.drools.event.process.ProcessEventListener listener)
|
void |
removeEventListener(RuleBaseEventListener listener)
Remove an event listener. |
void |
removeEventListener(WorkingMemoryEventListener listener)
Remove an event listener. |
void |
reset()
|
void |
reset(int handleId,
long handleCounter,
long propagationCounter)
|
void |
retract(org.drools.runtime.rule.FactHandle handle)
Retract a fact. |
void |
retract(FactHandle factHandle,
boolean removeLogical,
boolean updateEqualsMap,
Rule rule,
Activation activation)
|
void |
setAgendaEventSupport(AgendaEventSupport agendaEventSupport)
|
void |
setAsyncExceptionHandler(AsyncExceptionHandler handler)
Sets the AsyncExceptionHandler to handle exceptions thrown by the Agenda Scheduler used for duration rules. |
void |
setEndOperationListener(EndOperationListener listener)
|
void |
setFocus(String focus)
Set the focus to the specified AgendaGroup |
void |
setGlobal(String identifier,
Object value)
Set a specific instance as a global in this working memory. |
void |
setGlobalResolver(GlobalResolver globalResolver)
Sets the GlobalResolver instance to be used when resolving globals, replaces the current GlobalResolver. |
void |
setId(int id)
|
void |
setInitialFactHandle(InternalFactHandle initialFactHandle)
|
void |
setKnowledgeRuntime(InternalKnowledgeRuntime kruntime)
|
void |
setWorkingMemoryEventSupport(WorkingMemoryEventSupport 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. |
void |
startPartitionManagers()
This method is called to start the multiple partition threads when running in multi-thread mode |
org.drools.runtime.process.ProcessInstance |
startProcess(String processId)
Starts a new process instance for the process with the given id. |
org.drools.runtime.process.ProcessInstance |
startProcess(String processId,
Map<String,Object> parameters)
Starts a new process instance for the process with the given id. |
org.drools.runtime.process.ProcessInstance |
startProcessInstance(long processInstanceId)
|
void |
stopPartitionManagers()
|
void |
unregisterChannel(String name)
|
void |
unregisterExitPoint(String name)
Deprecated. Use unregisterChannel(String) instead. |
void |
update(org.drools.runtime.rule.FactHandle handle,
Object object)
Inform the WorkingMemory that a Fact has been modified and that it should now update the network. |
void |
update(org.drools.runtime.rule.FactHandle factHandle,
Object object,
Rule rule,
Activation activation)
|
void |
update(FactHandle factHandle,
Object object,
Rule rule,
Activation activation)
modify is implemented as half way retract / assert due to the truth maintenance issues. |
void |
updateEntryPointsCache()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.drools.common.InternalWorkingMemory |
---|
getEntryPoint |
Methods inherited from interface org.drools.WorkingMemory |
---|
getQueryResults |
Methods inherited from interface org.drools.runtime.rule.WorkingMemoryEntryPoint |
---|
getFactHandles, getFactHandles, getObjects, getObjects |
Methods inherited from interface org.drools.common.InternalWorkingMemoryEntryPoint |
---|
getEntryPoint, getInternalWorkingMemory |
Field Detail |
---|
protected int id
protected NamedEntryPoint defaultEntryPoint
protected GlobalResolver globalResolver
protected org.drools.runtime.Calendars calendars
protected DateFormats dateFormats
protected WorkingMemoryEventSupport workingMemoryEventSupport
protected AgendaEventSupport agendaEventSupport
protected List __ruleBaseEventListeners
protected transient InternalRuleBase ruleBase
RuleBase
with which this memory is associated.
protected FactHandleFactory handleFactory
protected InternalAgenda agenda
protected AtomicBoolean evaluatingActionQueue
protected ReentrantLock lock
protected boolean discardOnLogicalOverride
protected AtomicLong propagationIdCounter
protected volatile AtomicBoolean firing
protected Map<String,WorkingMemoryEntryPoint> entryPoints
protected InternalFactHandle initialFactHandle
protected SessionConfiguration config
protected PartitionManager partitionManager
protected transient AtomicReference<ExternalExecutorService> threadPool
Constructor Detail |
---|
public AbstractWorkingMemory()
public AbstractWorkingMemory(int id, InternalRuleBase ruleBase, FactHandleFactory handleFactory, SessionConfiguration config, org.drools.runtime.Environment environment)
ruleBase
- The backing rule-base.public AbstractWorkingMemory(int id, InternalRuleBase ruleBase, FactHandleFactory handleFactory, SessionConfiguration config, org.drools.runtime.Environment environment, WorkingMemoryEventSupport workingMemoryEventSupport, AgendaEventSupport agendaEventSupport)
public AbstractWorkingMemory(int id, InternalRuleBase ruleBase, FactHandleFactory handleFactory, InternalFactHandle initialFactHandle, long propagationContext, SessionConfiguration config, org.drools.runtime.Environment environment)
public AbstractWorkingMemory(int id, InternalRuleBase ruleBase, FactHandleFactory handleFactory, InternalFactHandle initialFactHandle, long propagationContext, SessionConfiguration config, org.drools.runtime.Environment environment, WorkingMemoryEventSupport workingMemoryEventSupport, AgendaEventSupport agendaEventSupport)
Method Detail |
---|
public String getEntryPointId()
getEntryPointId
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
public void updateEntryPointsCache()
updateEntryPointsCache
in interface InternalWorkingMemory
public void startPartitionManagers()
public void stopPartitionManagers()
public boolean isPartitionManagersActive()
public SessionConfiguration getSessionConfiguration()
getSessionConfiguration
in interface InternalWorkingMemory
public void reset()
reset
in interface InternalWorkingMemoryEntryPoint
public void reset(int handleId, long handleCounter, long propagationCounter)
public void setWorkingMemoryEventSupport(WorkingMemoryEventSupport workingMemoryEventSupport)
setWorkingMemoryEventSupport
in interface InternalWorkingMemory
public void setAgendaEventSupport(AgendaEventSupport agendaEventSupport)
setAgendaEventSupport
in interface InternalWorkingMemory
public boolean isSequential()
isSequential
in interface InternalWorkingMemory
public void addLIANodePropagation(LIANodePropagation liaNodePropagation)
addLIANodePropagation
in interface InternalWorkingMemory
public void addEventListener(WorkingMemoryEventListener listener)
WorkingMemoryEventManager
addEventListener
in interface WorkingMemoryEventManager
listener
- The listener to add.public void removeEventListener(WorkingMemoryEventListener listener)
WorkingMemoryEventManager
removeEventListener
in interface WorkingMemoryEventManager
listener
- The listener to remove.public List getWorkingMemoryEventListeners()
WorkingMemoryEventManager
getWorkingMemoryEventListeners
in interface EventSupport
getWorkingMemoryEventListeners
in interface WorkingMemoryEventManager
public void addEventListener(AgendaEventListener listener)
WorkingMemoryEventManager
addEventListener
in interface WorkingMemoryEventManager
listener
- The listener to add.public void removeEventListener(AgendaEventListener listener)
WorkingMemoryEventManager
removeEventListener
in interface WorkingMemoryEventManager
listener
- The listener to remove.public List getAgendaEventListeners()
WorkingMemoryEventManager
getAgendaEventListeners
in interface EventSupport
getAgendaEventListeners
in interface WorkingMemoryEventManager
public void addEventListener(RuleBaseEventListener listener)
RuleBaseEventManager
addEventListener
in interface RuleBaseEventManager
listener
- The listener to add.public List getRuleBaseEventListeners()
RuleBaseEventManager
getRuleBaseEventListeners
in interface RuleBaseEventManager
public void removeEventListener(RuleBaseEventListener listener)
RuleBaseEventManager
removeEventListener
in interface RuleBaseEventManager
listener
- The listener to remove.public void addEventListener(org.drools.event.process.ProcessEventListener listener)
addEventListener
in interface org.drools.event.process.ProcessEventManager
public Collection<org.drools.event.process.ProcessEventListener> getProcessEventListeners()
getProcessEventListeners
in interface org.drools.event.process.ProcessEventManager
public void removeEventListener(org.drools.event.process.ProcessEventListener listener)
removeEventListener
in interface org.drools.event.process.ProcessEventManager
public FactHandleFactory getFactHandleFactory()
getFactHandleFactory
in interface InternalWorkingMemory
public void setGlobal(String identifier, Object value)
WorkingMemory
setGlobal
in interface WorkingMemory
identifier
- the identifier under which to populate the datavalue
- the global value, cannot be nullpublic void setGlobalResolver(GlobalResolver globalResolver)
WorkingMemory
setGlobalResolver
in interface WorkingMemory
public GlobalResolver getGlobalResolver()
WorkingMemory
getGlobalResolver
in interface WorkingMemory
public org.drools.runtime.Calendars getCalendars()
getCalendars
in interface InternalWorkingMemory
public DateFormats getDateFormats()
getDateFormats
in interface InternalWorkingMemory
public int getId()
getId
in interface InternalWorkingMemory
public void setId(int id)
setId
in interface InternalWorkingMemory
public Object getGlobal(String identifier)
WorkingMemory
getGlobal
in interface WorkingMemory
public org.drools.runtime.Environment getEnvironment()
getEnvironment
in interface WorkingMemory
public Agenda getAgenda()
WorkingMemory
getAgenda
in interface WorkingMemory
public void clearAgenda()
WorkingMemory
clearAgenda
in interface WorkingMemory
public void clearAgendaGroup(String group)
WorkingMemory
clearAgendaGroup
in interface WorkingMemory
public void clearActivationGroup(String group)
WorkingMemory
clearActivationGroup
in interface WorkingMemory
public void clearRuleFlowGroup(String group)
WorkingMemory
clearRuleFlowGroup
in interface WorkingMemory
public RuleBase getRuleBase()
WorkingMemory
RuleBase
for this working memory.
getRuleBase
in interface InternalWorkingMemoryEntryPoint
getRuleBase
in interface WorkingMemory
RuleBase
.public void halt()
WorkingMemory
halt
in interface WorkingMemory
public int fireAllRules() throws FactException
WorkingMemory
fireAllRules
in interface WorkingMemory
FactException
- If a RuntimeException error occurs.public int fireAllRules(int fireLimit) throws FactException
WorkingMemory
fireAllRules
in interface WorkingMemory
FactException
- If a RuntimeException error occurs.public int fireAllRules(AgendaFilter agendaFilter) throws FactException
WorkingMemory
fireAllRules
in interface WorkingMemory
FactException
- If a RuntimeException error occurs.public int fireAllRules(AgendaFilter agendaFilter, int fireLimit) throws FactException
WorkingMemory
fireAllRules
in interface WorkingMemory
FactException
- If a RuntimeException error occurs.public void fireUntilHalt()
IllegalStateException
- if this method is called when running in sequential modepublic void fireUntilHalt(AgendaFilter agendaFilter)
agendaFilter
- filters the activations that may fire
IllegalStateException
- if this method is called when running in sequential modepublic Object getObject(org.drools.runtime.rule.FactHandle handle)
FactHandle
. It
actually attempts to return the value from the handle, before retrieving
it from objects map.
getObject
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
getObject
in interface WorkingMemory
handle
- The FactHandle
reference for the
Object
lookup
WorkingMemory
public ObjectStore getObjectStore()
getObjectStore
in interface InternalWorkingMemory
getObjectStore
in interface InternalWorkingMemoryEntryPoint
public FactHandle getFactHandle(Object object)
WorkingMemory
FactHandle
associated with an Object.
getFactHandle
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
getFactHandle
in interface WorkingMemory
object
- The object.
WorkingMemory
public FactHandle getFactHandleByIdentity(Object object)
InternalWorkingMemory
getFactHandleByIdentity
in interface InternalWorkingMemory
getFactHandleByIdentity
in interface InternalWorkingMemoryEntryPoint
getFactHandleByIdentity
in interface WorkingMemory
WorkingMemory
public Iterator iterateObjects()
iterateObjects
in interface WorkingMemory
public Iterator iterateObjects(org.drools.runtime.ObjectFilter filter)
iterateObjects
in interface WorkingMemory
public Iterator iterateFactHandles()
iterateFactHandles
in interface WorkingMemory
public Iterator iterateFactHandles(org.drools.runtime.ObjectFilter filter)
iterateFactHandles
in interface WorkingMemory
public abstract QueryResults getQueryResults(String query)
public void setFocus(String focus)
WorkingMemory
setFocus
in interface WorkingMemory
public TruthMaintenanceSystem getTruthMaintenanceSystem()
getTruthMaintenanceSystem
in interface InternalWorkingMemory
public FactHandle insert(Object object) throws FactException
WorkingMemoryEntryPoint
insert
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
object
- The fact object.
FactException
- If a RuntimeException error occurs.WorkingMemory
public FactHandle insertLogical(Object object) throws FactException
FactException
WorkingMemory
public FactHandle insert(Object object, boolean dynamic) throws FactException
WorkingMemoryEntryPoint
PropertyChangeListeners
on the Object to automatically trigger update
calls
if dynamic
is true
.
object
- The fact object.dynamic
- true if Drools should add JavaBean
PropertyChangeListeners
to the object.
FactException
- If a RuntimeException error occurs.public FactHandle insertLogical(Object object, boolean dynamic) throws FactException
insertLogical
in interface InternalWorkingMemoryActions
FactException
public FactHandle insert(Object object, boolean dynamic, boolean logical, Rule rule, Activation activation) throws FactException
insert
in interface InternalWorkingMemoryActions
FactException
public void insert(InternalFactHandle handle, Object object, Rule rule, Activation activation, ObjectTypeConf typeConf)
insert
in interface InternalWorkingMemory
public void retract(org.drools.runtime.rule.FactHandle handle) throws FactException
WorkingMemoryEntryPoint
retract
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
handle
- The fact-handle associated with the fact to retract.
FactException
- If a RuntimeException error occurs.public void retract(FactHandle factHandle, boolean removeLogical, boolean updateEqualsMap, Rule rule, Activation activation) throws FactException
retract
in interface InternalWorkingMemory
retract
in interface InternalWorkingMemoryActions
retract
in interface InternalWorkingMemoryEntryPoint
FactException
public EntryPointNode getEntryPointNode()
getEntryPointNode
in interface InternalWorkingMemory
getEntryPointNode
in interface InternalWorkingMemoryEntryPoint
public void update(org.drools.runtime.rule.FactHandle handle, Object object) throws FactException
WorkingMemoryEntryPoint
update
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
handle
- The fact-handle associated with the fact to modify.object
- The new value of the fact.
FactException
- If a RuntimeException error occurs.public void update(org.drools.runtime.rule.FactHandle factHandle, Object object, Rule rule, Activation activation) throws FactException
update
in interface InternalWorkingMemoryEntryPoint
FactException
public void update(FactHandle factHandle, Object object, Rule rule, Activation activation) throws FactException
update
in interface InternalWorkingMemoryActions
FactException
WorkingMemory
public void executeQueuedActions()
executeQueuedActions
in interface InternalWorkingMemory
public Queue<WorkingMemoryAction> getActionQueue()
public void queueWorkingMemoryAction(WorkingMemoryAction action)
queueWorkingMemoryAction
in interface InternalWorkingMemory
public Memory getNodeMemory(NodeMemory node)
JoinMemory
for a particular
JoinNode
.
getNodeMemory
in interface InternalWorkingMemory
node
- The JoinNode
key.
public void clearNodeMemory(NodeMemory node)
clearNodeMemory
in interface InternalWorkingMemory
public NodeMemories getNodeMemories()
getNodeMemories
in interface InternalWorkingMemory
public WorkingMemoryEventSupport getWorkingMemoryEventSupport()
getWorkingMemoryEventSupport
in interface EventSupport
public AgendaEventSupport getAgendaEventSupport()
getAgendaEventSupport
in interface EventSupport
public void setAsyncExceptionHandler(AsyncExceptionHandler handler)
setAsyncExceptionHandler
in interface WorkingMemory
handler
- public long getNextPropagationIdCounter()
getNextPropagationIdCounter
in interface InternalWorkingMemory
public long getPropagationIdCounter()
public Lock getLock()
getLock
in interface InternalWorkingMemory
public InternalProcessRuntime getProcessRuntime()
getProcessRuntime
in interface InternalWorkingMemory
public org.drools.runtime.process.ProcessInstance startProcess(String processId)
WorkingMemory
startProcess
in interface WorkingMemory
public org.drools.runtime.process.ProcessInstance startProcess(String processId, Map<String,Object> parameters)
WorkingMemory
startProcess
in interface WorkingMemory
public org.drools.runtime.process.ProcessInstance createProcessInstance(String processId, Map<String,Object> parameters)
public org.drools.runtime.process.ProcessInstance startProcessInstance(long processInstanceId)
public Collection<org.drools.runtime.process.ProcessInstance> getProcessInstances()
WorkingMemory
getProcessInstances
in interface WorkingMemory
public org.drools.runtime.process.ProcessInstance getProcessInstance(long processInstanceId)
WorkingMemory
getProcessInstance
in interface WorkingMemory
public org.drools.runtime.process.WorkItemManager getWorkItemManager()
getWorkItemManager
in interface WorkingMemory
public List iterateObjectsToList()
public List iterateNonDefaultEntryPointObjectsToList()
public Map.Entry[] getActivationParameters(long activationId)
public Map getActivationParameters(Activation activation)
public WorkingMemoryEntryPoint getWorkingMemoryEntryPoint(String name)
WorkingMemory
getWorkingMemoryEntryPoint
in interface WorkingMemory
name
- the id of the entry point, as defined in the rules filepublic Collection<WorkingMemoryEntryPoint> getWorkingMemoryEntryPoints()
public ObjectTypeConfigurationRegistry getObjectTypeConfigurationRegistry()
getObjectTypeConfigurationRegistry
in interface InternalWorkingMemory
getObjectTypeConfigurationRegistry
in interface InternalWorkingMemoryEntryPoint
public InternalFactHandle getInitialFactHandle()
getInitialFactHandle
in interface InternalWorkingMemory
public void setInitialFactHandle(InternalFactHandle initialFactHandle)
public TimerService getTimerService()
InternalWorkingMemory
getTimerService
in interface InternalWorkingMemory
public org.drools.time.SessionClock getSessionClock()
WorkingMemory
getSessionClock
in interface WorkingMemory
public PartitionTaskManager getPartitionTaskManager(RuleBasePartitionId partitionId)
InternalWorkingMemory
getPartitionTaskManager
in interface InternalWorkingMemory
partitionId
- the ID of the partition for which the task manager is assigned
public void startBatchExecution(ExecutionResultImpl results)
startBatchExecution
in interface InternalWorkingMemory
public ExecutionResultImpl getExecutionResult()
getExecutionResult
in interface InternalWorkingMemory
public void endBatchExecution()
endBatchExecution
in interface InternalWorkingMemory
public void dispose()
WorkingMemoryEntryPoint
public void setKnowledgeRuntime(InternalKnowledgeRuntime kruntime)
setKnowledgeRuntime
in interface InternalWorkingMemory
public InternalKnowledgeRuntime getKnowledgeRuntime()
getKnowledgeRuntime
in interface InternalWorkingMemory
@Deprecated public void registerExitPoint(String name, org.drools.runtime.ExitPoint exitPoint)
registerChannel(String, Channel)
instead.
@Deprecated public void unregisterExitPoint(String name)
unregisterChannel(String)
instead.
@Deprecated public Map<String,org.drools.runtime.ExitPoint> getExitPoints()
getChannels()
instead.
getExitPoints
in interface InternalWorkingMemory
public void registerChannel(String name, org.drools.runtime.Channel channel)
public void unregisterChannel(String name)
public Map<String,org.drools.runtime.Channel> getChannels()
InternalWorkingMemory
getChannels
in interface InternalWorkingMemory
public Map<String,WorkingMemoryEntryPoint> getEntryPoints()
getEntryPoints
in interface InternalWorkingMemory
public long getFactCount()
getFactCount
in interface org.drools.runtime.rule.WorkingMemoryEntryPoint
public long getTotalFactCount()
InternalWorkingMemory
getTotalFactCount
in interface InternalWorkingMemory
public void startOperation()
startOperation
in interface InternalWorkingMemory
public void setEndOperationListener(EndOperationListener listener)
public void endOperation()
endOperation
in interface InternalWorkingMemory
public long getIdleTime()
getIdleTime
in interface InternalWorkingMemory
public long getLastIdleTimestamp()
public long getTimeToNextJob()
getTimeToNextJob
in interface InternalWorkingMemory
public void prepareToFireActivation()
InternalWorkingMemory
prepareToFireActivation
in interface InternalWorkingMemory
public void activationFired()
InternalWorkingMemory
activationFired
in interface InternalWorkingMemory
public org.drools.marshalling.ObjectMarshallingStrategyStore getObjectMarshallingStrategyStore()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |