public class KieSessionResolver extends AbstractKieObjectsResolver implements org.kie.api.runtime.KieSession, org.kie.api.runtime.StatelessKieSession
releaseId
Constructor and Description |
---|
KieSessionResolver(org.kie.api.builder.ReleaseId releaseId,
List<KieListenerAdaptor> listeners,
List<KieLoggerAdaptor> loggers,
List<?> commands,
KSessionOptions kSessionOptions) |
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,
Map<String,Object> parameters) |
void |
delete(org.kie.api.runtime.rule.FactHandle handle) |
void |
delete(org.kie.api.runtime.rule.FactHandle handle,
org.kie.api.runtime.rule.FactHandle.State fhState) |
void |
destroy() |
void |
dispose() |
<T> T |
execute(org.kie.api.command.Command<T> command) |
void |
execute(Iterable objects) |
void |
execute(Object object) |
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) |
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.api.KieBase |
getKieBase() |
org.kie.api.logger.KieRuntimeLogger |
getLogger() |
Object |
getObject(org.kie.api.runtime.rule.FactHandle factHandle) |
Collection<? extends Object> |
getObjects() |
Collection<? extends Object> |
getObjects(org.kie.api.runtime.ObjectFilter filter) |
Collection<org.kie.api.event.process.ProcessEventListener> |
getProcessEventListeners() |
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() |
org.kie.api.runtime.rule.QueryResults |
getQueryResults(String query,
Object... arguments) |
Collection<org.kie.api.event.rule.RuleRuntimeEventListener> |
getRuleRuntimeEventListeners() |
<T extends org.kie.api.time.SessionClock> |
getSessionClock() |
org.kie.api.runtime.KieSessionConfiguration |
getSessionConfiguration() |
org.kie.api.runtime.process.WorkItemManager |
getWorkItemManager() |
void |
halt() |
Object |
init(BlueprintContextHelper context) |
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 |
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 |
setGlobal(String identifier,
Object value) |
void |
signalEvent(String type,
Object event) |
void |
signalEvent(String type,
Object event,
long processInstanceId) |
org.kie.api.runtime.process.ProcessInstance |
startProcess(String processId) |
org.kie.api.runtime.process.ProcessInstance |
startProcess(String processId,
Map<String,Object> parameters) |
org.kie.api.runtime.process.ProcessInstance |
startProcessInstance(long processInstanceId) |
void |
submit(org.kie.api.runtime.KieSession.AtomicAction action) |
void |
unregisterChannel(String name) |
void |
update(org.kie.api.runtime.rule.FactHandle handle,
Object object) |
void |
update(org.kie.api.runtime.rule.FactHandle handle,
Object object,
String... modifiedProperties) |
getBundleContext, newStatefulSession, newStatelessSession, resolveKBase, resolveKContainer, resolveKSession, resolveKSession, setBundleContext
public KieSessionResolver(org.kie.api.builder.ReleaseId releaseId, List<KieListenerAdaptor> listeners, List<KieLoggerAdaptor> loggers, List<?> commands, KSessionOptions kSessionOptions)
public Object init(BlueprintContextHelper context)
init
in interface Initializable
public int getId()
getId
in interface org.kie.api.runtime.KieSession
public long getIdentifier()
getIdentifier
in interface org.kie.api.runtime.KieSession
public void dispose()
dispose
in interface org.kie.api.runtime.KieSession
public void destroy()
destroy
in interface org.kie.api.runtime.KieSession
public <T> T execute(org.kie.api.command.Command<T> command)
execute
in interface org.kie.api.runtime.CommandExecutor
public <T extends org.kie.api.time.SessionClock> T getSessionClock()
getSessionClock
in interface org.kie.api.runtime.KieRuntime
public void setGlobal(String identifier, Object value)
setGlobal
in interface org.kie.api.runtime.KieRuntime
setGlobal
in interface org.kie.api.runtime.StatelessKieSession
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
getGlobals
in interface org.kie.api.runtime.StatelessKieSession
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 org.kie.api.KieBase getKieBase()
getKieBase
in interface org.kie.api.runtime.KieRuntime
getKieBase
in interface org.kie.api.runtime.StatelessKieSession
public void registerChannel(String name, org.kie.api.runtime.Channel channel)
registerChannel
in interface org.kie.api.runtime.KieRuntime
registerChannel
in interface org.kie.api.runtime.StatelessKieSession
public void unregisterChannel(String name)
unregisterChannel
in interface org.kie.api.runtime.KieRuntime
unregisterChannel
in interface org.kie.api.runtime.StatelessKieSession
public Map<String,org.kie.api.runtime.Channel> getChannels()
getChannels
in interface org.kie.api.runtime.KieRuntime
getChannels
in interface org.kie.api.runtime.StatelessKieSession
public org.kie.api.runtime.KieSessionConfiguration getSessionConfiguration()
getSessionConfiguration
in interface org.kie.api.runtime.KieRuntime
public void halt()
halt
in interface org.kie.api.runtime.rule.RuleRuntime
public org.kie.api.runtime.rule.Agenda getAgenda()
getAgenda
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 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.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 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 delete(org.kie.api.runtime.rule.FactHandle handle, org.kie.api.runtime.rule.FactHandle.State fhState)
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 update(org.kie.api.runtime.rule.FactHandle handle, Object object, String... modifiedProperties)
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 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 <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 long getFactCount()
getFactCount
in interface org.kie.api.runtime.rule.EntryPoint
public org.kie.api.logger.KieRuntimeLogger getLogger()
getLogger
in interface org.kie.api.event.KieRuntimeEventManager
public void addEventListener(org.kie.api.event.process.ProcessEventListener listener)
addEventListener
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 Collection<org.kie.api.event.process.ProcessEventListener> getProcessEventListeners()
getProcessEventListeners
in interface org.kie.api.event.process.ProcessEventManager
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 Collection<org.kie.api.runtime.process.ProcessInstance> getProcessInstances()
getProcessInstances
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 void abortProcessInstance(long processInstanceId)
abortProcessInstance
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 void addEventListener(org.kie.api.event.rule.RuleRuntimeEventListener listener)
addEventListener
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 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
public void removeEventListener(org.kie.api.event.rule.AgendaEventListener listener)
removeEventListener
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 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 void submit(org.kie.api.runtime.KieSession.AtomicAction action)
submit
in interface org.kie.api.runtime.KieSession
public void execute(Object object)
execute
in interface org.kie.api.runtime.rule.StatelessRuleSession
public void execute(Iterable objects)
execute
in interface org.kie.api.runtime.rule.StatelessRuleSession
Copyright © 2001–2017 JBoss by Red Hat. All rights reserved.