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 ConcurrentMap<Long,ReentrantLock> |
engineLocks |
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 org.kie.internal.runtime.manager.RuntimeManagerRegistry |
registry |
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) |
abstract void |
init() |
protected boolean |
isActive() |
boolean |
isClosed() |
protected boolean |
isUseLocking() |
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 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 ConcurrentMap<Long,ReentrantLock> engineLocks
public AbstractRuntimeManager(org.kie.api.runtime.manager.RuntimeEnvironment environment, String identifier)
public abstract 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 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
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 createLockOnNewProcessInstance(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.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–2018 JBoss by Red Hat. All rights reserved.