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.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(long processInstanceId)
getProcessInstance
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(long processInstanceId, boolean readonly)
getProcessInstance
in interface org.kie.api.runtime.process.ProcessRuntime
public Collection<org.kie.api.runtime.process.ProcessInstance> getProcessInstances()
getProcessInstances
in interface org.kie.api.runtime.process.ProcessRuntime
public void signalEvent(String type, Object event)
signalEvent
in interface org.kie.api.runtime.process.ProcessRuntime
public void signalEvent(String type, Object event, long processInstanceId)
signalEvent
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance startProcess(String processId)
startProcess
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance startProcess(String processId, Map<String,Object> parameters)
startProcess
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance createProcessInstance(String processId, Map<String,Object> parameters)
createProcessInstance
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance startProcessInstance(long processInstanceId)
startProcessInstance
in interface org.kie.api.runtime.process.ProcessRuntime
public void addEventListener(org.kie.api.event.process.ProcessEventListener listener)
addEventListener
in interface org.kie.api.event.process.ProcessEventManager
public Collection<org.kie.api.event.process.ProcessEventListener> getProcessEventListeners()
getProcessEventListeners
in interface org.kie.api.event.process.ProcessEventManager
public void removeEventListener(org.kie.api.event.process.ProcessEventListener listener)
removeEventListener
in interface org.kie.api.event.process.ProcessEventManager
public org.kie.internal.KnowledgeBase getKieBase()
getKieBase
in interface org.kie.api.runtime.KieRuntime
getKieBase
in interface org.kie.internal.runtime.StatefulKnowledgeSession
public org.kie.api.runtime.process.WorkItemManager getWorkItemManager()
getWorkItemManager
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.Environment getEnvironment()
getEnvironment
in interface org.kie.api.runtime.KieRuntime
public InternalProcessRuntime getProcessRuntime()
getProcessRuntime
in interface org.drools.core.common.InternalKnowledgeRuntime
public org.kie.api.runtime.KieSessionConfiguration getSessionConfiguration()
getSessionConfiguration
in interface org.kie.api.runtime.KieRuntime
public org.drools.core.time.TimerService getTimerService()
getTimerService
in interface org.drools.core.common.InternalKnowledgeRuntime
public void startOperation()
startOperation
in interface org.drools.core.common.InternalKnowledgeRuntime
public void endOperation()
endOperation
in interface org.drools.core.common.InternalKnowledgeRuntime
public void executeQueuedActions()
executeQueuedActions
in interface org.drools.core.common.InternalKnowledgeRuntime
public Queue<org.drools.core.common.WorkingMemoryAction> getActionQueue()
public void queueWorkingMemoryAction(org.drools.core.common.WorkingMemoryAction action)
queueWorkingMemoryAction
in interface org.drools.core.common.InternalKnowledgeRuntime
public void dispose()
dispose
in interface org.kie.api.runtime.KieSession
public void setId(Long id)
setId
in interface org.drools.core.common.InternalKnowledgeRuntime
public int getId()
getId
in interface org.kie.api.runtime.KieSession
public void setEndOperationListener(org.drools.core.common.EndOperationListener listener)
setEndOperationListener
in interface org.drools.core.common.InternalKnowledgeRuntime
public int fireAllRules()
fireAllRules
in interface org.kie.api.runtime.rule.StatefulRuleSession
public int fireAllRules(int max)
fireAllRules
in interface org.kie.api.runtime.rule.StatefulRuleSession
public int fireAllRules(org.kie.api.runtime.rule.AgendaFilter agendaFilter)
fireAllRules
in interface org.kie.api.runtime.rule.StatefulRuleSession
public int fireAllRules(org.kie.api.runtime.rule.AgendaFilter agendaFilter, int i)
fireAllRules
in interface org.kie.api.runtime.rule.StatefulRuleSession
public void fireUntilHalt()
fireUntilHalt
in interface org.kie.api.runtime.rule.StatefulRuleSession
public void fireUntilHalt(org.kie.api.runtime.rule.AgendaFilter agendaFilter)
fireUntilHalt
in interface org.kie.api.runtime.rule.StatefulRuleSession
public <T> T execute(org.kie.api.command.Command<T> command)
execute
in interface org.kie.api.runtime.CommandExecutor
public org.kie.api.runtime.Calendars getCalendars()
getCalendars
in interface org.kie.api.runtime.KieRuntime
public Map<String,org.kie.api.runtime.Channel> getChannels()
getChannels
in interface org.kie.api.runtime.KieRuntime
public Object getGlobal(String identifier)
getGlobal
in interface org.kie.api.runtime.KieRuntime
public org.kie.api.runtime.Globals getGlobals()
getGlobals
in interface org.kie.api.runtime.KieRuntime
public org.kie.api.time.SessionClock getSessionClock()
getSessionClock
in interface org.kie.api.runtime.KieRuntime
public void registerChannel(String name, org.kie.api.runtime.Channel channel)
registerChannel
in interface org.kie.api.runtime.KieRuntime
public void setGlobal(String identifier, Object object)
setGlobal
in interface org.kie.api.runtime.KieRuntime
public void unregisterChannel(String name)
unregisterChannel
in interface org.kie.api.runtime.KieRuntime
public org.kie.api.runtime.rule.Agenda getAgenda()
getAgenda
in interface org.kie.api.runtime.rule.RuleRuntime
public org.kie.api.runtime.rule.QueryResults getQueryResults(String query, Object... arguments)
getQueryResults
in interface org.kie.api.runtime.rule.RuleRuntime
public org.kie.api.runtime.rule.EntryPoint getEntryPoint(String name)
getEntryPoint
in interface org.kie.api.runtime.rule.RuleRuntime
public Collection<? extends org.kie.api.runtime.rule.EntryPoint> getEntryPoints()
getEntryPoints
in interface org.kie.api.runtime.rule.RuleRuntime
public void halt()
halt
in interface org.kie.api.runtime.rule.RuleRuntime
public 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.RuleRuntime
public String getEntryPointId()
getEntryPointId
in interface org.kie.api.runtime.rule.EntryPoint
public long getFactCount()
getFactCount
in interface org.kie.api.runtime.rule.EntryPoint
public org.kie.api.runtime.rule.FactHandle getFactHandle(Object object)
getFactHandle
in interface org.kie.api.runtime.rule.EntryPoint
public <T extends org.kie.api.runtime.rule.FactHandle> Collection<T> getFactHandles()
getFactHandles
in interface org.kie.api.runtime.rule.EntryPoint
public <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.EntryPoint
public Object getObject(org.kie.api.runtime.rule.FactHandle factHandle)
getObject
in interface org.kie.api.runtime.rule.EntryPoint
public Collection<Object> getObjects()
getObjects
in interface org.kie.api.runtime.rule.EntryPoint
public Collection<Object> getObjects(org.kie.api.runtime.ObjectFilter filter)
getObjects
in interface org.kie.api.runtime.rule.EntryPoint
public org.kie.api.runtime.rule.FactHandle insert(Object object)
insert
in interface org.kie.api.runtime.rule.EntryPoint
public void retract(org.kie.api.runtime.rule.FactHandle handle)
retract
in interface org.kie.api.runtime.rule.EntryPoint
public void delete(org.kie.api.runtime.rule.FactHandle handle)
delete
in interface org.kie.api.runtime.rule.EntryPoint
public void update(org.kie.api.runtime.rule.FactHandle handle, Object object)
update
in interface org.kie.api.runtime.rule.EntryPoint
public void addEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener)
addEventListener
in interface org.kie.api.event.rule.RuleRuntimeEventManager
public void addEventListener(org.kie.api.event.rule.AgendaEventListener listener)
addEventListener
in interface org.kie.api.event.rule.RuleRuntimeEventManager
public Collection<org.kie.api.event.rule.AgendaEventListener> getAgendaEventListeners()
getAgendaEventListeners
in interface org.kie.api.event.rule.RuleRuntimeEventManager
public Collection<org.kie.api.event.rule.RuleRuntimeEventListener> getRuleRuntimeEventListeners()
getRuleRuntimeEventListeners
in interface org.kie.api.event.rule.RuleRuntimeEventManager
public void removeEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener)
removeEventListener
in interface org.kie.api.event.rule.RuleRuntimeEventManager
public void removeEventListener(org.kie.api.event.rule.AgendaEventListener listener)
removeEventListener
in interface org.kie.api.event.rule.RuleRuntimeEventManager
public long getLastIdleTimestamp()
getLastIdleTimestamp
in interface org.drools.core.common.InternalKnowledgeRuntime
public 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.CorrelationAwareProcessRuntime
public 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.CorrelationAwareProcessRuntime
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(org.kie.internal.process.CorrelationKey correlationKey)
getProcessInstance
in interface org.kie.internal.process.CorrelationAwareProcessRuntime
public void destroy()
destroy
in interface org.kie.api.runtime.KieSession
public long getIdentifier()
getIdentifier
in interface org.kie.api.runtime.KieSession
Copyright © 2001–2015 JBoss by Red Hat. All rights reserved.