public class StatefulProcessSession
extends org.drools.core.impl.AbstractRuntime
implements org.kie.internal.runtime.StatefulKnowledgeSession, org.drools.core.common.InternalKnowledgeRuntime, org.kie.internal.process.CorrelationAwareProcessRuntime
| Modifier and Type | Field and Description |
|---|---|
protected Queue<org.drools.core.common.WorkingMemoryAction> |
actionQueue |
| Constructor and Description |
|---|
StatefulProcessSession(org.kie.internal.KnowledgeBase kbase,
org.kie.api.runtime.KieSessionConfiguration sessionConfiguration,
org.kie.api.runtime.Environment environment) |
| Modifier and Type | Method and Description |
|---|---|
void |
abortProcessInstance(long processInstanceId) |
void |
addEventListener(org.kie.api.event.rule.AgendaEventListener listener) |
void |
addEventListener(org.kie.api.event.process.ProcessEventListener listener) |
void |
addEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener) |
org.kie.api.runtime.process.ProcessInstance |
createProcessInstance(String processId,
org.kie.internal.process.CorrelationKey correlationKey,
Map<String,Object> parameters) |
org.kie.api.runtime.process.ProcessInstance |
createProcessInstance(String processId,
Map<String,Object> parameters) |
void |
delete(org.kie.api.runtime.rule.FactHandle handle) |
void |
destroy() |
void |
dispose() |
void |
endOperation() |
<T> T |
execute(org.kie.api.command.Command<T> command) |
void |
executeQueuedActions() |
int |
fireAllRules() |
int |
fireAllRules(org.kie.api.runtime.rule.AgendaFilter agendaFilter) |
int |
fireAllRules(org.kie.api.runtime.rule.AgendaFilter agendaFilter,
int i) |
int |
fireAllRules(int max) |
void |
fireUntilHalt() |
void |
fireUntilHalt(org.kie.api.runtime.rule.AgendaFilter agendaFilter) |
Queue<org.drools.core.common.WorkingMemoryAction> |
getActionQueue() |
org.kie.api.runtime.rule.Agenda |
getAgenda() |
Collection<org.kie.api.event.rule.AgendaEventListener> |
getAgendaEventListeners() |
org.kie.api.runtime.Calendars |
getCalendars() |
Map<String,org.kie.api.runtime.Channel> |
getChannels() |
org.kie.api.runtime.rule.EntryPoint |
getEntryPoint(String name) |
String |
getEntryPointId() |
Collection<? extends org.kie.api.runtime.rule.EntryPoint> |
getEntryPoints() |
org.kie.api.runtime.Environment |
getEnvironment() |
long |
getFactCount() |
org.kie.api.runtime.rule.FactHandle |
getFactHandle(Object object) |
<T extends org.kie.api.runtime.rule.FactHandle> |
getFactHandles() |
<T extends org.kie.api.runtime.rule.FactHandle> |
getFactHandles(org.kie.api.runtime.ObjectFilter filter) |
Object |
getGlobal(String identifier) |
org.kie.api.runtime.Globals |
getGlobals() |
int |
getId() |
long |
getIdentifier() |
org.kie.internal.KnowledgeBase |
getKieBase() |
long |
getLastIdleTimestamp() |
Object |
getObject(org.kie.api.runtime.rule.FactHandle factHandle) |
Collection<Object> |
getObjects() |
Collection<Object> |
getObjects(org.kie.api.runtime.ObjectFilter filter) |
Collection<org.kie.api.event.process.ProcessEventListener> |
getProcessEventListeners() |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(org.kie.internal.process.CorrelationKey correlationKey) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(long processInstanceId) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(long processInstanceId,
boolean readonly) |
Collection<org.kie.api.runtime.process.ProcessInstance> |
getProcessInstances() |
InternalProcessRuntime |
getProcessRuntime() |
org.kie.api.runtime.rule.QueryResults |
getQueryResults(String query,
Object... arguments) |
Collection<org.kie.api.event.rule.RuleRuntimeEventListener> |
getRuleRuntimeEventListeners() |
org.kie.api.time.SessionClock |
getSessionClock() |
org.kie.api.runtime.KieSessionConfiguration |
getSessionConfiguration() |
org.drools.core.time.TimerService |
getTimerService() |
org.kie.api.runtime.process.WorkItemManager |
getWorkItemManager() |
void |
halt() |
org.kie.api.runtime.rule.FactHandle |
insert(Object object) |
org.kie.api.runtime.rule.LiveQuery |
openLiveQuery(String query,
Object[] arguments,
org.kie.api.runtime.rule.ViewChangedEventListener listener) |
void |
queueWorkingMemoryAction(org.drools.core.common.WorkingMemoryAction action) |
void |
registerChannel(String name,
org.kie.api.runtime.Channel channel) |
void |
removeEventListener(org.kie.api.event.rule.AgendaEventListener listener) |
void |
removeEventListener(org.kie.api.event.process.ProcessEventListener listener) |
void |
removeEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener) |
void |
retract(org.kie.api.runtime.rule.FactHandle handle) |
void |
setEndOperationListener(org.drools.core.common.EndOperationListener listener) |
void |
setGlobal(String identifier,
Object object) |
void |
setId(Long id) |
void |
signalEvent(String type,
Object event) |
void |
signalEvent(String type,
Object event,
long processInstanceId) |
void |
startOperation() |
org.kie.api.runtime.process.ProcessInstance |
startProcess(String processId) |
org.kie.api.runtime.process.ProcessInstance |
startProcess(String processId,
org.kie.internal.process.CorrelationKey correlationKey,
Map<String,Object> parameters) |
org.kie.api.runtime.process.ProcessInstance |
startProcess(String processId,
Map<String,Object> parameters) |
org.kie.api.runtime.process.ProcessInstance |
startProcessInstance(long processInstanceId) |
void |
unregisterChannel(String name) |
void |
update(org.kie.api.runtime.rule.FactHandle handle,
Object object) |
protected Queue<org.drools.core.common.WorkingMemoryAction> actionQueue
public StatefulProcessSession(org.kie.internal.KnowledgeBase kbase,
org.kie.api.runtime.KieSessionConfiguration sessionConfiguration,
org.kie.api.runtime.Environment environment)
public void abortProcessInstance(long processInstanceId)
abortProcessInstance in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance getProcessInstance(long processInstanceId)
getProcessInstance in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance getProcessInstance(long processInstanceId,
boolean readonly)
getProcessInstance in interface org.kie.api.runtime.process.ProcessRuntimepublic Collection<org.kie.api.runtime.process.ProcessInstance> getProcessInstances()
getProcessInstances in interface org.kie.api.runtime.process.ProcessRuntimepublic void signalEvent(String type, Object event)
signalEvent in interface org.kie.api.runtime.process.ProcessRuntimepublic void signalEvent(String type, Object event, long processInstanceId)
signalEvent in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance startProcess(String processId)
startProcess in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance startProcess(String processId, Map<String,Object> parameters)
startProcess in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance createProcessInstance(String processId, Map<String,Object> parameters)
createProcessInstance in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance startProcessInstance(long processInstanceId)
startProcessInstance in interface org.kie.api.runtime.process.ProcessRuntimepublic void addEventListener(org.kie.api.event.process.ProcessEventListener listener)
addEventListener in interface org.kie.api.event.process.ProcessEventManagerpublic Collection<org.kie.api.event.process.ProcessEventListener> getProcessEventListeners()
getProcessEventListeners in interface org.kie.api.event.process.ProcessEventManagerpublic void removeEventListener(org.kie.api.event.process.ProcessEventListener listener)
removeEventListener in interface org.kie.api.event.process.ProcessEventManagerpublic org.kie.internal.KnowledgeBase getKieBase()
getKieBase in interface org.kie.api.runtime.KieRuntimegetKieBase in interface org.kie.internal.runtime.StatefulKnowledgeSessionpublic org.kie.api.runtime.process.WorkItemManager getWorkItemManager()
getWorkItemManager in interface org.kie.api.runtime.process.ProcessRuntimepublic org.kie.api.runtime.Environment getEnvironment()
getEnvironment in interface org.kie.api.runtime.KieRuntimepublic InternalProcessRuntime getProcessRuntime()
getProcessRuntime in interface org.drools.core.common.InternalKnowledgeRuntimepublic org.kie.api.runtime.KieSessionConfiguration getSessionConfiguration()
getSessionConfiguration in interface org.kie.api.runtime.KieRuntimepublic org.drools.core.time.TimerService getTimerService()
getTimerService in interface org.drools.core.common.InternalKnowledgeRuntimepublic void startOperation()
startOperation in interface org.drools.core.common.InternalKnowledgeRuntimepublic void endOperation()
endOperation in interface org.drools.core.common.InternalKnowledgeRuntimepublic void executeQueuedActions()
executeQueuedActions in interface org.drools.core.common.InternalKnowledgeRuntimepublic Queue<org.drools.core.common.WorkingMemoryAction> getActionQueue()
public void queueWorkingMemoryAction(org.drools.core.common.WorkingMemoryAction action)
queueWorkingMemoryAction in interface org.drools.core.common.InternalKnowledgeRuntimepublic void dispose()
dispose in interface org.kie.api.runtime.KieSessionpublic void setId(Long id)
setId in interface org.drools.core.common.InternalKnowledgeRuntimepublic int getId()
getId in interface org.kie.api.runtime.KieSessionpublic void setEndOperationListener(org.drools.core.common.EndOperationListener listener)
setEndOperationListener in interface org.drools.core.common.InternalKnowledgeRuntimepublic int fireAllRules()
fireAllRules in interface org.kie.api.runtime.rule.StatefulRuleSessionpublic int fireAllRules(int max)
fireAllRules in interface org.kie.api.runtime.rule.StatefulRuleSessionpublic int fireAllRules(org.kie.api.runtime.rule.AgendaFilter agendaFilter)
fireAllRules in interface org.kie.api.runtime.rule.StatefulRuleSessionpublic int fireAllRules(org.kie.api.runtime.rule.AgendaFilter agendaFilter,
int i)
fireAllRules in interface org.kie.api.runtime.rule.StatefulRuleSessionpublic void fireUntilHalt()
fireUntilHalt in interface org.kie.api.runtime.rule.StatefulRuleSessionpublic void fireUntilHalt(org.kie.api.runtime.rule.AgendaFilter agendaFilter)
fireUntilHalt in interface org.kie.api.runtime.rule.StatefulRuleSessionpublic <T> T execute(org.kie.api.command.Command<T> command)
execute in interface org.kie.api.runtime.CommandExecutorpublic org.kie.api.runtime.Calendars getCalendars()
getCalendars in interface org.kie.api.runtime.KieRuntimepublic Map<String,org.kie.api.runtime.Channel> getChannels()
getChannels in interface org.kie.api.runtime.KieRuntimepublic Object getGlobal(String identifier)
getGlobal in interface org.kie.api.runtime.KieRuntimepublic org.kie.api.runtime.Globals getGlobals()
getGlobals in interface org.kie.api.runtime.KieRuntimepublic org.kie.api.time.SessionClock getSessionClock()
getSessionClock in interface org.kie.api.runtime.KieRuntimepublic void registerChannel(String name, org.kie.api.runtime.Channel channel)
registerChannel in interface org.kie.api.runtime.KieRuntimepublic void setGlobal(String identifier, Object object)
setGlobal in interface org.kie.api.runtime.KieRuntimepublic void unregisterChannel(String name)
unregisterChannel in interface org.kie.api.runtime.KieRuntimepublic org.kie.api.runtime.rule.Agenda getAgenda()
getAgenda in interface org.kie.api.runtime.rule.RuleRuntimepublic org.kie.api.runtime.rule.QueryResults getQueryResults(String query, Object... arguments)
getQueryResults in interface org.kie.api.runtime.rule.RuleRuntimepublic org.kie.api.runtime.rule.EntryPoint getEntryPoint(String name)
getEntryPoint in interface org.kie.api.runtime.rule.RuleRuntimepublic Collection<? extends org.kie.api.runtime.rule.EntryPoint> getEntryPoints()
getEntryPoints in interface org.kie.api.runtime.rule.RuleRuntimepublic void halt()
halt in interface org.kie.api.runtime.rule.RuleRuntimepublic org.kie.api.runtime.rule.LiveQuery openLiveQuery(String query, Object[] arguments, org.kie.api.runtime.rule.ViewChangedEventListener listener)
openLiveQuery in interface org.kie.api.runtime.rule.RuleRuntimepublic String getEntryPointId()
getEntryPointId in interface org.kie.api.runtime.rule.EntryPointpublic long getFactCount()
getFactCount in interface org.kie.api.runtime.rule.EntryPointpublic org.kie.api.runtime.rule.FactHandle getFactHandle(Object object)
getFactHandle in interface org.kie.api.runtime.rule.EntryPointpublic <T extends org.kie.api.runtime.rule.FactHandle> Collection<T> getFactHandles()
getFactHandles in interface org.kie.api.runtime.rule.EntryPointpublic <T extends org.kie.api.runtime.rule.FactHandle> Collection<T> getFactHandles(org.kie.api.runtime.ObjectFilter filter)
getFactHandles in interface org.kie.api.runtime.rule.EntryPointpublic Object getObject(org.kie.api.runtime.rule.FactHandle factHandle)
getObject in interface org.kie.api.runtime.rule.EntryPointpublic Collection<Object> getObjects()
getObjects in interface org.kie.api.runtime.rule.EntryPointpublic Collection<Object> getObjects(org.kie.api.runtime.ObjectFilter filter)
getObjects in interface org.kie.api.runtime.rule.EntryPointpublic org.kie.api.runtime.rule.FactHandle insert(Object object)
insert in interface org.kie.api.runtime.rule.EntryPointpublic void retract(org.kie.api.runtime.rule.FactHandle handle)
retract in interface org.kie.api.runtime.rule.EntryPointpublic void delete(org.kie.api.runtime.rule.FactHandle handle)
delete in interface org.kie.api.runtime.rule.EntryPointpublic void update(org.kie.api.runtime.rule.FactHandle handle,
Object object)
update in interface org.kie.api.runtime.rule.EntryPointpublic void addEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener)
addEventListener in interface org.kie.api.event.rule.RuleRuntimeEventManagerpublic void addEventListener(org.kie.api.event.rule.AgendaEventListener listener)
addEventListener in interface org.kie.api.event.rule.RuleRuntimeEventManagerpublic Collection<org.kie.api.event.rule.AgendaEventListener> getAgendaEventListeners()
getAgendaEventListeners in interface org.kie.api.event.rule.RuleRuntimeEventManagerpublic Collection<org.kie.api.event.rule.RuleRuntimeEventListener> getRuleRuntimeEventListeners()
getRuleRuntimeEventListeners in interface org.kie.api.event.rule.RuleRuntimeEventManagerpublic void removeEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener)
removeEventListener in interface org.kie.api.event.rule.RuleRuntimeEventManagerpublic void removeEventListener(org.kie.api.event.rule.AgendaEventListener listener)
removeEventListener in interface org.kie.api.event.rule.RuleRuntimeEventManagerpublic long getLastIdleTimestamp()
getLastIdleTimestamp in interface org.drools.core.common.InternalKnowledgeRuntimepublic org.kie.api.runtime.process.ProcessInstance startProcess(String processId, org.kie.internal.process.CorrelationKey correlationKey, Map<String,Object> parameters)
startProcess in interface org.kie.internal.process.CorrelationAwareProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance createProcessInstance(String processId, org.kie.internal.process.CorrelationKey correlationKey, Map<String,Object> parameters)
createProcessInstance in interface org.kie.internal.process.CorrelationAwareProcessRuntimepublic org.kie.api.runtime.process.ProcessInstance getProcessInstance(org.kie.internal.process.CorrelationKey correlationKey)
getProcessInstance in interface org.kie.internal.process.CorrelationAwareProcessRuntimepublic void destroy()
destroy in interface org.kie.api.runtime.KieSessionpublic long getIdentifier()
getIdentifier in interface org.kie.api.runtime.KieSessionCopyright © 2001–2015 JBoss by Red Hat. All rights reserved.