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 |
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
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.InternalRuntimeManager
public void close()
close
in interface org.kie.api.runtime.manager.RuntimeManager
public void close(boolean removeJobs)
public org.kie.internal.runtime.manager.RuntimeEnvironment getEnvironment()
getEnvironment
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public void setEnvironment(org.kie.api.runtime.manager.RuntimeEnvironment environment)
public String getIdentifier()
getIdentifier
in interface org.kie.api.runtime.manager.RuntimeManager
public 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.InternalRuntimeManager
public void setDeploymentDescriptor(org.kie.internal.runtime.conf.DeploymentDescriptor deploymentDescriptor)
setDeploymentDescriptor
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public void setSecurityManager(org.kie.internal.runtime.manager.SecurityManager securityManager)
setSecurityManager
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public boolean hasSecurityManager()
hasSecurityManager
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
protected void checkPermission()
public void setCacheManager(org.kie.internal.runtime.manager.CacheManager cacheManager)
setCacheManager
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public org.kie.internal.runtime.manager.CacheManager getCacheManager()
getCacheManager
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public org.kie.api.runtime.KieContainer getKieContainer()
getKieContainer
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public void setKieContainer(org.kie.api.runtime.KieContainer kieContainer)
setKieContainer
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
protected boolean isUseLocking()
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(Long id, org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void createLockOnNewProcessInstance(Long id, org.kie.api.runtime.manager.RuntimeEngine runtime)
protected void releaseAndCleanLock(org.kie.api.runtime.manager.RuntimeEngine runtime)
protected boolean isActive()
public void activate()
activate
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public void deactivate()
deactivate
in interface org.kie.internal.runtime.manager.InternalRuntimeManager
public 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.