public abstract class AbstractRuntimeManager extends Object implements org.kie.internal.runtime.manager.InternalRuntimeManager
RuntimeManager implementations should inherit from.
Provides the following capabilities:
init method that will be called on RuntimeManager instantiation.| Modifier and Type | Field and Description |
|---|---|
protected org.kie.internal.runtime.manager.CacheManager |
cacheManager |
protected boolean |
closed |
protected org.kie.internal.runtime.conf.DeploymentDescriptor |
deploymentDescriptor |
protected boolean |
engineInitEager |
protected org.kie.api.runtime.manager.RuntimeEnvironment |
environment |
protected org.kie.internal.runtime.error.ExecutionErrorManager |
executionErrorManager |
protected String |
identifier |
protected org.kie.api.runtime.KieContainer |
kieContainer |
protected RuntimeManagerLockStrategyFactory |
lockStrategyFactory |
protected org.kie.internal.runtime.manager.RuntimeManagerRegistry |
registry |
protected RuntimeManagerLockStrategy |
runtimeManagerLockStrategy |
protected org.kie.internal.runtime.manager.SecurityManager |
securityManager |
protected RuntimeManagerLockWatcherSingletonService |
watcher |
| Constructor and Description |
|---|
AbstractRuntimeManager(org.kie.api.runtime.manager.RuntimeEnvironment environment,
String identifier) |
| Modifier and Type | Method and Description |
|---|---|
void |
activate() |
protected void |
attachManager(org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected boolean |
canDestroy(org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected boolean |
canDispose(org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected void |
checkPermission() |
void |
close() |
void |
close(boolean removeJobs) |
protected void |
configureRuntimeOnTaskService(org.kie.internal.task.api.InternalTaskService internalTaskService,
org.kie.api.runtime.manager.RuntimeEngine engine) |
protected void |
createLockOnGetEngine(org.kie.api.runtime.manager.Context<?> context,
org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected void |
createLockOnGetEngine(Long id,
org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected void |
createLockOnNewProcessInstance(Long id,
org.kie.api.runtime.manager.RuntimeEngine runtime) |
void |
deactivate() |
org.kie.internal.runtime.manager.CacheManager |
getCacheManager() |
org.kie.internal.runtime.conf.DeploymentDescriptor |
getDeploymentDescriptor() |
org.kie.internal.runtime.manager.RuntimeEnvironment |
getEnvironment() |
org.kie.internal.runtime.error.ExecutionErrorManager |
getExecutionErrorManager() |
abstract org.kie.internal.runtime.manager.SessionFactory |
getFactory() |
String |
getIdentifier() |
org.kie.api.runtime.KieContainer |
getKieContainer() |
protected org.drools.persistence.api.TransactionManager |
getTransactionManager(org.kie.api.runtime.Environment env) |
protected org.drools.persistence.api.TransactionManager |
getTransactionManagerInternal(org.kie.api.runtime.Environment env) |
protected boolean |
hasEnvironmentEntry(String name,
Object value) |
boolean |
hasSecurityManager() |
void |
init() |
protected boolean |
isActive() |
boolean |
isClosed() |
protected boolean |
isUseLocking() |
protected org.kie.internal.task.api.InternalTaskService |
newTaskService(org.kie.internal.runtime.manager.TaskServiceFactory factory) |
protected void |
registerDisposeCallback(org.kie.api.runtime.manager.RuntimeEngine runtime,
org.drools.persistence.api.TransactionSynchronization sync,
org.kie.api.runtime.Environment environment) |
protected void |
registerItems(org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected void |
releaseAndCleanLock(Long id,
org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected void |
releaseAndCleanLock(org.kie.api.runtime.manager.RuntimeEngine runtime) |
protected void |
removeRuntimeFromTaskService() |
void |
setCacheManager(org.kie.internal.runtime.manager.CacheManager cacheManager) |
void |
setDeploymentDescriptor(org.kie.internal.runtime.conf.DeploymentDescriptor deploymentDescriptor) |
void |
setEnvironment(org.kie.api.runtime.manager.RuntimeEnvironment environment) |
void |
setIdentifier(String identifier) |
void |
setKieContainer(org.kie.api.runtime.KieContainer kieContainer) |
void |
setSecurityManager(org.kie.internal.runtime.manager.SecurityManager securityManager) |
void |
softDispose(org.kie.api.runtime.manager.RuntimeEngine runtimeEngine)
Soft dispose means it will be invoked as sort of preparation step before actual dispose.
|
protected org.kie.internal.runtime.manager.RuntimeManagerRegistry registry
protected RuntimeManagerLockStrategyFactory lockStrategyFactory
protected org.kie.api.runtime.manager.RuntimeEnvironment environment
protected org.kie.internal.runtime.conf.DeploymentDescriptor deploymentDescriptor
protected org.kie.api.runtime.KieContainer kieContainer
protected org.kie.internal.runtime.manager.CacheManager cacheManager
protected boolean engineInitEager
protected String identifier
protected boolean closed
protected org.kie.internal.runtime.manager.SecurityManager securityManager
protected org.kie.internal.runtime.error.ExecutionErrorManager executionErrorManager
protected RuntimeManagerLockStrategy runtimeManagerLockStrategy
protected RuntimeManagerLockWatcherSingletonService watcher
public AbstractRuntimeManager(org.kie.api.runtime.manager.RuntimeEnvironment environment,
String identifier)
public void init()
protected void registerItems(org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void registerDisposeCallback(org.kie.api.runtime.manager.RuntimeEngine runtime,
org.drools.persistence.api.TransactionSynchronization sync,
org.kie.api.runtime.Environment environment)
protected boolean canDispose(org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void attachManager(org.kie.api.runtime.manager.RuntimeEngine runtime)
public boolean isClosed()
isClosed in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic void close()
close in interface org.kie.api.runtime.manager.RuntimeManagerpublic void close(boolean removeJobs)
public org.kie.internal.runtime.manager.RuntimeEnvironment getEnvironment()
getEnvironment in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic void setEnvironment(org.kie.api.runtime.manager.RuntimeEnvironment environment)
public String getIdentifier()
getIdentifier in interface org.kie.api.runtime.manager.RuntimeManagerpublic void setIdentifier(String identifier)
protected org.kie.internal.task.api.InternalTaskService newTaskService(org.kie.internal.runtime.manager.TaskServiceFactory factory)
protected void configureRuntimeOnTaskService(org.kie.internal.task.api.InternalTaskService internalTaskService,
org.kie.api.runtime.manager.RuntimeEngine engine)
protected void removeRuntimeFromTaskService()
public void softDispose(org.kie.api.runtime.manager.RuntimeEngine runtimeEngine)
protected boolean canDestroy(org.kie.api.runtime.manager.RuntimeEngine runtime)
protected org.drools.persistence.api.TransactionManager getTransactionManager(org.kie.api.runtime.Environment env)
protected org.drools.persistence.api.TransactionManager getTransactionManagerInternal(org.kie.api.runtime.Environment env)
public org.kie.internal.runtime.conf.DeploymentDescriptor getDeploymentDescriptor()
getDeploymentDescriptor in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic void setDeploymentDescriptor(org.kie.internal.runtime.conf.DeploymentDescriptor deploymentDescriptor)
setDeploymentDescriptor in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic void setSecurityManager(org.kie.internal.runtime.manager.SecurityManager securityManager)
setSecurityManager in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic boolean hasSecurityManager()
hasSecurityManager in interface org.kie.internal.runtime.manager.InternalRuntimeManagerprotected void checkPermission()
public void setCacheManager(org.kie.internal.runtime.manager.CacheManager cacheManager)
setCacheManager in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic org.kie.internal.runtime.manager.CacheManager getCacheManager()
getCacheManager in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic org.kie.api.runtime.KieContainer getKieContainer()
getKieContainer in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic void setKieContainer(org.kie.api.runtime.KieContainer kieContainer)
setKieContainer in interface org.kie.internal.runtime.manager.InternalRuntimeManagerprotected boolean isUseLocking()
protected void createLockOnNewProcessInstance(Long id, org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void createLockOnGetEngine(org.kie.api.runtime.manager.Context<?> context,
org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void createLockOnGetEngine(Long id, org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void releaseAndCleanLock(org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void releaseAndCleanLock(Long id, org.kie.api.runtime.manager.RuntimeEngine runtime)
protected boolean isActive()
public void activate()
activate in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic void deactivate()
deactivate in interface org.kie.internal.runtime.manager.InternalRuntimeManagerpublic org.kie.internal.runtime.error.ExecutionErrorManager getExecutionErrorManager()
public abstract org.kie.internal.runtime.manager.SessionFactory getFactory()
Copyright © 2001–2021 JBoss by Red Hat. All rights reserved.