Package org.jbpm.executor.impl
Class AbstractAvailableJobsExecutor
- java.lang.Object
-
- org.jbpm.executor.impl.AbstractAvailableJobsExecutor
-
- Direct Known Subclasses:
AvailableJobsExecutor,JmsAvailableJobsExecutor
public abstract class AbstractAvailableJobsExecutor extends Object
Heart of the executor component - executes the actual tasks. Handles retries and error management. Based on results of execution notifies defined callbacks about the execution results.
-
-
Field Summary
Fields Modifier and Type Field Description protected ClassCacheManagerclassCacheManagerprotected Map<String,Object>contextDataprotected ExecutorEventSupporteventSupportprotected org.kie.api.executor.Executorexecutorprotected org.kie.api.executor.ExecutorStoreServiceexecutorStoreServiceprotected org.kie.api.executor.ExecutorQueryServicequeryServiceprotected intretries
-
Constructor Summary
Constructors Constructor Description AbstractAvailableJobsExecutor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddContextData(String name, Object data)voidexecuteGivenJob(RequestInfo request)protected ClassLoadergetClassLoader(String deploymentId)protected voidhandleCompletion(boolean processReoccurring, org.kie.api.executor.Command cmd, org.kie.api.executor.CommandContext ctx)protected booleanhandleException(RequestInfo request, Throwable e, org.kie.api.executor.CommandContext ctx, List<org.kie.api.executor.CommandCallback> callbacks)voidsetClassCacheManager(ClassCacheManager classCacheManager)voidsetEventSupport(ExecutorEventSupport eventSupport)voidsetExecutor(org.kie.api.executor.Executor executor)voidsetExecutorStoreService(org.kie.api.executor.ExecutorStoreService executorStoreService)voidsetQueryService(org.kie.api.executor.ExecutorQueryService queryService)protected voidupdateProcessInfoInContext(RequestInfo requestInfo, org.kie.api.executor.CommandContext ctx)
-
-
-
Field Detail
-
retries
protected int retries
-
queryService
protected org.kie.api.executor.ExecutorQueryService queryService
-
classCacheManager
protected ClassCacheManager classCacheManager
-
executorStoreService
protected org.kie.api.executor.ExecutorStoreService executorStoreService
-
eventSupport
protected ExecutorEventSupport eventSupport
-
executor
protected org.kie.api.executor.Executor executor
-
-
Method Detail
-
setEventSupport
public void setEventSupport(ExecutorEventSupport eventSupport)
-
setQueryService
public void setQueryService(org.kie.api.executor.ExecutorQueryService queryService)
-
setClassCacheManager
public void setClassCacheManager(ClassCacheManager classCacheManager)
-
setExecutorStoreService
public void setExecutorStoreService(org.kie.api.executor.ExecutorStoreService executorStoreService)
-
setExecutor
public void setExecutor(org.kie.api.executor.Executor executor)
-
executeGivenJob
public void executeGivenJob(RequestInfo request)
-
getClassLoader
protected ClassLoader getClassLoader(String deploymentId)
-
handleException
protected boolean handleException(RequestInfo request, Throwable e, org.kie.api.executor.CommandContext ctx, List<org.kie.api.executor.CommandCallback> callbacks)
-
handleCompletion
protected void handleCompletion(boolean processReoccurring, org.kie.api.executor.Command cmd, org.kie.api.executor.CommandContext ctx)
-
updateProcessInfoInContext
protected void updateProcessInfoInContext(RequestInfo requestInfo, org.kie.api.executor.CommandContext ctx)
-
-