public class ExecutorServiceImpl extends Object implements org.kie.internal.executor.api.ExecutorService, RequeueAware
| Constructor and Description |
|---|
ExecutorServiceImpl() |
ExecutorServiceImpl(org.kie.api.executor.Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
void |
addAsyncJobListener(AsynchronousJobListener listener) |
void |
cancelRequest(Long requestId) |
int |
clearAllErrors() |
int |
clearAllRequests() |
void |
destroy() |
org.kie.api.executor.ExecutorAdminService |
getAdminService() |
List<org.kie.api.executor.ErrorInfo> |
getAllErrors() |
List<org.kie.api.executor.ErrorInfo> |
getAllErrors(org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getAllRequests() |
List<org.kie.api.executor.RequestInfo> |
getAllRequests(org.kie.api.runtime.query.QueryContext queryContext) |
List<AsynchronousJobListener> |
getAsyncJobListeners() |
List<org.kie.api.executor.RequestInfo> |
getCancelledRequests() |
List<org.kie.api.executor.RequestInfo> |
getCancelledRequests(org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getCompletedRequests() |
List<org.kie.api.executor.RequestInfo> |
getCompletedRequests(org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.ErrorInfo> |
getErrorsByRequestId(Long requestId) |
ExecutorEventSupport |
getEventSupport() |
org.kie.api.executor.Executor |
getExecutor() |
List<org.kie.api.executor.RequestInfo> |
getFutureQueuedRequests() |
List<org.kie.api.executor.RequestInfo> |
getFutureQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getInErrorRequests() |
List<org.kie.api.executor.RequestInfo> |
getInErrorRequests(org.kie.api.runtime.query.QueryContext queryContext) |
int |
getInterval() |
List<org.kie.api.executor.RequestInfo> |
getPendingRequestById(Long id) |
List<org.kie.api.executor.RequestInfo> |
getPendingRequests() |
List<org.kie.api.executor.RequestInfo> |
getPendingRequests(org.kie.api.runtime.query.QueryContext queryContext) |
org.kie.api.executor.ExecutorQueryService |
getQueryService() |
List<org.kie.api.executor.RequestInfo> |
getQueuedRequests() |
List<org.kie.api.executor.RequestInfo> |
getQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext) |
org.kie.api.executor.RequestInfo |
getRequestById(Long requestId) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByBusinessKey(String businessKey,
List<org.kie.api.executor.STATUS> statuses,
org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByBusinessKey(String businessKey,
org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByCommand(String command,
List<org.kie.api.executor.STATUS> statuses,
org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByCommand(String command,
org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByDeployment(String deploymentId,
List<org.kie.api.executor.STATUS> statuses,
org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByProcessInstance(Long processInstanceId,
List<org.kie.api.executor.STATUS> statuses,
org.kie.api.runtime.query.QueryContext queryContext) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByStatus(List<org.kie.api.executor.STATUS> statuses) |
List<org.kie.api.executor.RequestInfo> |
getRequestsByStatus(List<org.kie.api.executor.STATUS> statuses,
org.kie.api.runtime.query.QueryContext queryContext) |
int |
getRetries() |
List<org.kie.api.executor.RequestInfo> |
getRunningRequests() |
List<org.kie.api.executor.RequestInfo> |
getRunningRequests(org.kie.api.runtime.query.QueryContext queryContext) |
int |
getThreadPoolSize() |
TimeUnit |
getTimeunit() |
void |
init() |
boolean |
isActive() |
void |
removeAsyncJobListener(AsynchronousJobListener listener) |
void |
requeue(Long olderThan)
Moves
RequestInfo instances that are in running state longer than
given amount of time (time unit depends on the org.kie.executor.timeunit system property) |
void |
requeueById(Long requestId)
Moves
RequestInfo instance with given request id that are in running state |
Long |
scheduleRequest(String commandName,
org.kie.api.executor.CommandContext ctx) |
Long |
scheduleRequest(String commandId,
Date date,
org.kie.api.executor.CommandContext ctx) |
void |
setAdminService(org.kie.api.executor.ExecutorAdminService adminService) |
void |
setEventSupport(ExecutorEventSupport eventSupport) |
void |
setExecutor(org.kie.api.executor.Executor executor) |
void |
setInterval(int waitTime) |
void |
setQueryService(org.kie.api.executor.ExecutorQueryService queryService) |
void |
setRetries(int defaultNroOfRetries) |
void |
setThreadPoolSize(int nroOfThreads) |
void |
setTimeunit(TimeUnit timeunit) |
void |
updateRequestData(Long requestId,
Map<String,Object> data) |
public ExecutorServiceImpl()
public ExecutorServiceImpl(org.kie.api.executor.Executor executor)
public ExecutorEventSupport getEventSupport()
public void setEventSupport(ExecutorEventSupport eventSupport)
public org.kie.api.executor.Executor getExecutor()
public void setExecutor(org.kie.api.executor.Executor executor)
public org.kie.api.executor.ExecutorQueryService getQueryService()
public void setQueryService(org.kie.api.executor.ExecutorQueryService queryService)
public org.kie.api.executor.ExecutorAdminService getAdminService()
public void setAdminService(org.kie.api.executor.ExecutorAdminService adminService)
public List<org.kie.api.executor.RequestInfo> getFutureQueuedRequests()
public List<org.kie.api.executor.RequestInfo> getQueuedRequests()
public List<org.kie.api.executor.RequestInfo> getCompletedRequests()
public List<org.kie.api.executor.RequestInfo> getInErrorRequests()
public List<org.kie.api.executor.RequestInfo> getCancelledRequests()
public List<org.kie.api.executor.ErrorInfo> getAllErrors()
public List<org.kie.api.executor.RequestInfo> getAllRequests()
public List<org.kie.api.executor.RequestInfo> getRequestsByStatus(List<org.kie.api.executor.STATUS> statuses)
public int clearAllRequests()
clearAllRequests in interface org.kie.api.executor.ExecutorServicepublic int clearAllErrors()
clearAllErrors in interface org.kie.api.executor.ExecutorServicepublic Long scheduleRequest(String commandName, org.kie.api.executor.CommandContext ctx)
scheduleRequest in interface org.kie.api.executor.ExecutorServicepublic void cancelRequest(Long requestId)
cancelRequest in interface org.kie.api.executor.ExecutorServicepublic void init()
init in interface org.kie.api.executor.ExecutorServicepublic void destroy()
destroy in interface org.kie.api.executor.ExecutorServicepublic boolean isActive()
isActive in interface org.kie.api.executor.ExecutorServicepublic int getInterval()
getInterval in interface org.kie.api.executor.ExecutorServicepublic void setInterval(int waitTime)
setInterval in interface org.kie.api.executor.ExecutorServicepublic int getRetries()
getRetries in interface org.kie.api.executor.ExecutorServicepublic void setRetries(int defaultNroOfRetries)
setRetries in interface org.kie.api.executor.ExecutorServicepublic int getThreadPoolSize()
getThreadPoolSize in interface org.kie.api.executor.ExecutorServicepublic void setThreadPoolSize(int nroOfThreads)
setThreadPoolSize in interface org.kie.api.executor.ExecutorServicepublic TimeUnit getTimeunit()
getTimeunit in interface org.kie.api.executor.ExecutorServicepublic void setTimeunit(TimeUnit timeunit)
setTimeunit in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getPendingRequests()
public List<org.kie.api.executor.RequestInfo> getPendingRequestById(Long id)
getPendingRequestById in interface org.kie.api.executor.ExecutorServicepublic Long scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
scheduleRequest in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRunningRequests()
public org.kie.api.executor.RequestInfo getRequestById(Long requestId)
getRequestById in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.ErrorInfo> getErrorsByRequestId(Long requestId)
getErrorsByRequestId in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRequestsByBusinessKey(String businessKey, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByBusinessKey in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRequestsByCommand(String command, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByCommand in interface org.kie.api.executor.ExecutorServicepublic void requeue(Long olderThan)
RequeueAwareRequestInfo instances that are in running state longer than
given amount of time (time unit depends on the org.kie.executor.timeunit system property)requeue in interface RequeueAwareolderThan - amount of time from current time stamppublic void requeueById(Long requestId)
RequeueAwareRequestInfo instance with given request id that are in running staterequeueById in interface RequeueAwarerequestId - request unique identifierpublic List<org.kie.api.executor.RequestInfo> getQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
getQueuedRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getCompletedRequests(org.kie.api.runtime.query.QueryContext queryContext)
getCompletedRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getInErrorRequests(org.kie.api.runtime.query.QueryContext queryContext)
getInErrorRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getCancelledRequests(org.kie.api.runtime.query.QueryContext queryContext)
getCancelledRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.ErrorInfo> getAllErrors(org.kie.api.runtime.query.QueryContext queryContext)
getAllErrors in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getAllRequests(org.kie.api.runtime.query.QueryContext queryContext)
getAllRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRequestsByStatus(List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByStatus in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getPendingRequests(org.kie.api.runtime.query.QueryContext queryContext)
getPendingRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRunningRequests(org.kie.api.runtime.query.QueryContext queryContext)
getRunningRequests in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getFutureQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
getFutureQueuedRequests in interface org.kie.api.executor.ExecutorServicepublic void addAsyncJobListener(AsynchronousJobListener listener)
public void removeAsyncJobListener(AsynchronousJobListener listener)
public List<AsynchronousJobListener> getAsyncJobListeners()
public List<org.kie.api.executor.RequestInfo> getRequestsByBusinessKey(String businessKey, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByBusinessKey in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRequestsByCommand(String command, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByCommand in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRequestsByDeployment(String deploymentId, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByDeployment in interface org.kie.api.executor.ExecutorServicepublic List<org.kie.api.executor.RequestInfo> getRequestsByProcessInstance(Long processInstanceId, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByProcessInstance in interface org.kie.api.executor.ExecutorServiceCopyright © 2001–2018 JBoss by Red Hat. All rights reserved.