public class StatefulKnowledgeSessionImpl extends AbstractRuntime implements org.kie.internal.runtime.StatefulKnowledgeSession, InternalWorkingMemoryEntryPoint, InternalKnowledgeRuntime, org.kie.api.runtime.KieSession, org.kie.internal.process.CorrelationAwareProcessRuntime
Modifier and Type | Class and Description |
---|---|
static class |
StatefulKnowledgeSessionImpl.AbstractImmutableCollection |
static class |
StatefulKnowledgeSessionImpl.AgendaEventListenerWrapper |
static class |
StatefulKnowledgeSessionImpl.AgendaFilterWrapper |
static class |
StatefulKnowledgeSessionImpl.ObjectStoreWrapper |
static class |
StatefulKnowledgeSessionImpl.RuleRuntimeEventListenerWrapper |
Modifier and Type | Field and Description |
---|---|
org.kie.internal.KnowledgeBase |
kbase |
ReteooWorkingMemoryInterface |
session |
logger
Constructor and Description |
---|
StatefulKnowledgeSessionImpl(AbstractWorkingMemory session) |
StatefulKnowledgeSessionImpl(AbstractWorkingMemory session,
org.kie.internal.KnowledgeBase kbase) |
Modifier and Type | Method and Description |
---|---|
void |
abortProcessInstance(long id) |
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) |
void |
addEventListener(org.kie.api.event.rule.WorkingMemoryEventListener listener)
Deprecated.
|
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 factHandle) |
void |
delete(FactHandle factHandle,
Rule rule,
Activation activation) |
void |
destroy() |
void |
dispose() |
void |
endOperation() |
<T> T |
execute(org.kie.api.command.Command<T> command) |
<T> T |
execute(org.kie.internal.command.Context context,
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 max) |
int |
fireAllRules(int max) |
void |
fireUntilHalt() |
void |
fireUntilHalt(org.kie.api.runtime.rule.AgendaFilter agendaFilter) |
Queue<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() |
EntryPointId |
getEntryPoint() |
org.kie.api.runtime.rule.EntryPoint |
getEntryPoint(String name) |
String |
getEntryPointId() |
EntryPointNode |
getEntryPointNode() |
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) |
FactHandle |
getFactHandleByIdentity(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() |
InternalWorkingMemory |
getInternalWorkingMemory() |
org.kie.internal.KnowledgeBase |
getKieBase() |
long |
getLastIdleTimestamp() |
Object |
getObject(org.kie.api.runtime.rule.FactHandle factHandle) |
Collection<? extends Object> |
getObjects() |
Collection<? extends Object> |
getObjects(org.kie.api.runtime.ObjectFilter filter) |
ObjectStore |
getObjectStore() |
ObjectTypeConfigurationRegistry |
getObjectTypeConfigurationRegistry() |
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 id) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(long id,
boolean readOnly) |
Collection<org.kie.api.runtime.process.ProcessInstance> |
getProcessInstances() |
InternalProcessRuntime |
getProcessRuntime() |
org.kie.api.runtime.rule.QueryResults |
getQueryResults(String query,
Object... arguments) |
RuleBase |
getRuleBase() |
Collection<org.kie.api.event.rule.RuleRuntimeEventListener> |
getRuleRuntimeEventListeners() |
<T extends org.kie.api.time.SessionClock> |
getSessionClock() |
org.kie.api.runtime.KieSessionConfiguration |
getSessionConfiguration() |
TimerService |
getTimerService() |
Collection<org.kie.api.event.rule.WorkingMemoryEventListener> |
getWorkingMemoryEventListeners()
Deprecated.
|
org.kie.api.runtime.process.WorkItemManager |
getWorkItemManager() |
void |
halt() |
org.kie.api.runtime.rule.FactHandle |
insert(Object object) |
boolean |
isAlive() |
org.kie.api.runtime.rule.LiveQuery |
openLiveQuery(String query,
Object[] arguments,
org.kie.api.runtime.rule.ViewChangedEventListener listener) |
void |
queueWorkingMemoryAction(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 |
removeEventListener(org.kie.api.event.rule.WorkingMemoryEventListener listener)
Deprecated.
|
void |
reset() |
void |
retract(org.kie.api.runtime.rule.FactHandle factHandle) |
void |
setEndOperationListener(EndOperationListener listener) |
void |
setGlobal(String identifier,
Object object) |
void |
setId(int 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 factHandle) |
void |
update(org.kie.api.runtime.rule.FactHandle factHandle,
Object object) |
void |
update(org.kie.api.runtime.rule.FactHandle factHandle,
Object object,
long mask,
Class<?> modifiedClass,
Activation activation) |
getLogger, setLogger
public ReteooWorkingMemoryInterface session
public org.kie.internal.KnowledgeBase kbase
public StatefulKnowledgeSessionImpl(AbstractWorkingMemory session)
public StatefulKnowledgeSessionImpl(AbstractWorkingMemory session, org.kie.internal.KnowledgeBase kbase)
public void reset()
reset
in interface InternalWorkingMemoryEntryPoint
public ObjectStore getObjectStore()
getObjectStore
in interface InternalWorkingMemoryEntryPoint
public EntryPointNode getEntryPointNode()
getEntryPointNode
in interface InternalWorkingMemoryEntryPoint
public int getId()
getId
in interface org.kie.api.runtime.KieSession
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 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.WorkingMemoryEventListener listener)
addEventListener
in interface org.kie.api.event.rule.WorkingMemoryEventManager
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.WorkingMemoryEventListener listener)
removeEventListener
in interface org.kie.api.event.rule.WorkingMemoryEventManager
public Collection<org.kie.api.event.rule.WorkingMemoryEventListener> getWorkingMemoryEventListeners()
getWorkingMemoryEventListeners
in interface org.kie.api.event.rule.WorkingMemoryEventManager
public Collection<org.kie.api.event.rule.RuleRuntimeEventListener> getRuleRuntimeEventListeners()
getRuleRuntimeEventListeners
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
addEventListener
in interface org.kie.api.event.rule.WorkingMemoryEventManager
public Collection<org.kie.api.event.rule.AgendaEventListener> getAgendaEventListeners()
getAgendaEventListeners
in interface org.kie.api.event.rule.RuleRuntimeEventManager
getAgendaEventListeners
in interface org.kie.api.event.rule.WorkingMemoryEventManager
public void removeEventListener(org.kie.api.event.rule.AgendaEventListener listener)
removeEventListener
in interface org.kie.api.event.rule.RuleRuntimeEventManager
removeEventListener
in interface org.kie.api.event.rule.WorkingMemoryEventManager
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 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 max)
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 extends org.kie.api.time.SessionClock> T getSessionClock()
getSessionClock
in interface org.kie.api.runtime.KieRuntime
public void halt()
halt
in interface org.kie.api.runtime.rule.RuleRuntime
public void dispose()
dispose
in interface org.kie.api.runtime.KieSession
public boolean isAlive()
public void destroy()
destroy
in interface org.kie.api.runtime.KieSession
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 factHandle)
retract
in interface org.kie.api.runtime.rule.EntryPoint
public void delete(org.kie.api.runtime.rule.FactHandle factHandle)
delete
in interface org.kie.api.runtime.rule.EntryPoint
public void update(org.kie.api.runtime.rule.FactHandle factHandle)
public void update(org.kie.api.runtime.rule.FactHandle factHandle, Object object)
update
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 Object getObject(org.kie.api.runtime.rule.FactHandle factHandle)
getObject
in interface org.kie.api.runtime.rule.EntryPoint
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(long id)
getProcessInstance
in interface org.kie.api.runtime.process.ProcessRuntime
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(long id, boolean readOnly)
getProcessInstance
in interface org.kie.api.runtime.process.ProcessRuntime
public void abortProcessInstance(long id)
abortProcessInstance
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 org.kie.api.runtime.process.WorkItemManager getWorkItemManager()
getWorkItemManager
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 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 void setGlobal(String identifier, Object object)
setGlobal
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.runtime.Calendars getCalendars()
getCalendars
in interface org.kie.api.runtime.KieRuntime
public org.kie.api.runtime.Environment getEnvironment()
getEnvironment
in interface org.kie.api.runtime.KieRuntime
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 Collection<? extends Object> getObjects()
getObjects
in interface org.kie.api.runtime.rule.EntryPoint
public Collection<? extends Object> getObjects(org.kie.api.runtime.ObjectFilter filter)
getObjects
in interface org.kie.api.runtime.rule.EntryPoint
public void delete(FactHandle factHandle, Rule rule, Activation activation) throws FactException
delete
in interface InternalWorkingMemoryEntryPoint
FactException
public void update(org.kie.api.runtime.rule.FactHandle factHandle, Object object, long mask, Class<?> modifiedClass, Activation activation) throws FactException
update
in interface InternalWorkingMemoryEntryPoint
FactException
public EntryPointId getEntryPoint()
getEntryPoint
in interface InternalWorkingMemoryEntryPoint
public InternalWorkingMemory getInternalWorkingMemory()
getInternalWorkingMemory
in interface InternalWorkingMemoryEntryPoint
public FactHandle getFactHandleByIdentity(Object object)
getFactHandleByIdentity
in interface InternalWorkingMemoryEntryPoint
public org.kie.api.runtime.rule.Agenda getAgenda()
getAgenda
in interface org.kie.api.runtime.rule.RuleRuntime
public void registerChannel(String name, org.kie.api.runtime.Channel channel)
registerChannel
in interface org.kie.api.runtime.KieRuntime
public void unregisterChannel(String name)
unregisterChannel
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 ObjectTypeConfigurationRegistry getObjectTypeConfigurationRegistry()
getObjectTypeConfigurationRegistry
in interface InternalWorkingMemoryEntryPoint
public RuleBase getRuleBase()
getRuleBase
in interface InternalWorkingMemoryEntryPoint
public org.kie.api.runtime.rule.QueryResults getQueryResults(String query, Object... arguments)
getQueryResults
in interface org.kie.api.runtime.rule.RuleRuntime
public <T> T execute(org.kie.api.command.Command<T> command)
execute
in interface org.kie.api.runtime.CommandExecutor
public <T> T execute(org.kie.internal.command.Context context, org.kie.api.command.Command<T> command)
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.LiveQuery openLiveQuery(String query, Object[] arguments, org.kie.api.runtime.rule.ViewChangedEventListener listener)
openLiveQuery
in interface org.kie.api.runtime.rule.RuleRuntime
public org.kie.api.runtime.KieSessionConfiguration getSessionConfiguration()
getSessionConfiguration
in interface org.kie.api.runtime.KieRuntime
public TimerService getTimerService()
getTimerService
in interface InternalKnowledgeRuntime
public void startOperation()
startOperation
in interface InternalKnowledgeRuntime
public void endOperation()
endOperation
in interface InternalKnowledgeRuntime
public void executeQueuedActions()
executeQueuedActions
in interface InternalKnowledgeRuntime
public Queue<WorkingMemoryAction> getActionQueue()
getActionQueue
in interface InternalKnowledgeRuntime
public InternalProcessRuntime getProcessRuntime()
getProcessRuntime
in interface InternalKnowledgeRuntime
public void queueWorkingMemoryAction(WorkingMemoryAction action)
queueWorkingMemoryAction
in interface InternalKnowledgeRuntime
public void setId(int id)
setId
in interface InternalKnowledgeRuntime
public void setEndOperationListener(EndOperationListener listener)
setEndOperationListener
in interface InternalKnowledgeRuntime
public long getLastIdleTimestamp()
getLastIdleTimestamp
in interface 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
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.