public class AgendaGroupQueueImpl extends Object implements InternalAgendaGroup, InternalRuleFlowGroup
AgendaGroup
implementation that uses a PriorityQueue
to prioritise the evaluation of added
ActivationQueue
s. The AgendaGroup
also maintains a Map
of ActivationQueues
for requested salience values.PriorityQueue
Modifier and Type | Class and Description |
---|---|
class |
AgendaGroupQueueImpl.ClearAction |
static class |
AgendaGroupQueueImpl.DeactivateCallback |
class |
AgendaGroupQueueImpl.SetFocusAction |
Modifier and Type | Field and Description |
---|---|
protected BinaryHeapQueue |
priorityQueue
Items in the agenda.
|
MAIN
Constructor and Description |
---|
AgendaGroupQueueImpl(String name,
InternalKnowledgeBase kBase) |
protected final BinaryHeapQueue priorityQueue
public AgendaGroupQueueImpl(String name, InternalKnowledgeBase kBase)
protected BinaryHeapQueue initPriorityQueue(InternalKnowledgeBase kBase)
public void visited()
visited
in interface InternalAgendaGroup
public String getName()
getName
in interface org.kie.api.runtime.rule.AgendaGroup
getName
in interface org.kie.api.runtime.rule.RuleFlowGroup
public void setWorkingMemory(InternalWorkingMemory workingMemory)
setWorkingMemory
in interface InternalAgendaGroup
public InternalWorkingMemory getWorkingMemory()
getWorkingMemory
in interface InternalAgendaGroup
public void hasRuleFlowListener(boolean hasRuleFlowLister)
hasRuleFlowListener
in interface InternalAgendaGroup
public boolean isRuleFlowListener()
isRuleFlowListener
in interface InternalAgendaGroup
public void clear()
clear
in interface org.kie.api.runtime.rule.AgendaGroup
clear
in interface org.kie.api.runtime.rule.RuleFlowGroup
public void setFocus()
setFocus
in interface org.kie.api.runtime.rule.AgendaGroup
public void reset()
reset
in interface InternalAgendaGroup
public Activation[] getAndClear()
getAndClear
in interface InternalAgendaGroup
public int size()
public void add(Activation activation)
add
in interface InternalAgendaGroup
public Activation remove()
remove
in interface InternalAgendaGroup
public Activation peek()
peek
in interface InternalAgendaGroup
public boolean isActive()
public boolean isAutoDeactivate()
isAutoDeactivate
in interface InternalAgendaGroup
public void setAutoDeactivate(boolean autoDeactivate)
InternalAgendaGroup
setAutoDeactivate
in interface InternalAgendaGroup
public void addNodeInstance(Long processInstanceId, String nodeInstanceId)
addNodeInstance
in interface InternalAgendaGroup
public void removeNodeInstance(Long processInstanceId, String nodeInstanceId)
removeNodeInstance
in interface InternalAgendaGroup
public void setActive(boolean activate)
setActive
in interface InternalAgendaGroup
public PropagationContext getAutoFocusActivator()
public void setAutoFocusActivator(PropagationContext autoFocusActivator)
public boolean isEmpty()
public Activation[] getActivations()
getActivations
in interface InternalAgendaGroup
public Map<Long,String> getNodeInstances()
getNodeInstances
in interface InternalAgendaGroup
public void remove(Activation activation)
remove
in interface InternalAgendaGroup
public long getActivatedForRecency()
getActivatedForRecency
in interface InternalAgendaGroup
public void setActivatedForRecency(long recency)
setActivatedForRecency
in interface InternalAgendaGroup
public long getClearedForRecency()
getClearedForRecency
in interface InternalAgendaGroup
public void setClearedForRecency(long recency)
setClearedForRecency
in interface InternalAgendaGroup
public boolean isSequential()
isSequential
in interface InternalAgendaGroup
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.