public class ExecutorServiceImpl extends Object implements org.kie.internal.executor.api.ExecutorService, RequeueAware
| Constructor and Description |
|---|
ExecutorServiceImpl() |
ExecutorServiceImpl(org.kie.internal.executor.api.Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancelRequest(Long requestId) |
int |
clearAllErrors() |
int |
clearAllRequests() |
void |
destroy() |
org.kie.internal.executor.api.ExecutorAdminService |
getAdminService() |
List<org.kie.internal.executor.api.ErrorInfo> |
getAllErrors() |
List<org.kie.internal.executor.api.RequestInfo> |
getAllRequests() |
List<org.kie.internal.executor.api.RequestInfo> |
getCancelledRequests() |
List<org.kie.internal.executor.api.RequestInfo> |
getCompletedRequests() |
List<org.kie.internal.executor.api.ErrorInfo> |
getErrorsByRequestId(Long requestId) |
org.kie.internal.executor.api.Executor |
getExecutor() |
List<org.kie.internal.executor.api.RequestInfo> |
getFutureQueuedRequests() |
List<org.kie.internal.executor.api.RequestInfo> |
getInErrorRequests() |
int |
getInterval() |
List<org.kie.internal.executor.api.RequestInfo> |
getPendingRequestById(Long id) |
List<org.kie.internal.executor.api.RequestInfo> |
getPendingRequests() |
org.kie.internal.executor.api.ExecutorQueryService |
getQueryService() |
List<org.kie.internal.executor.api.RequestInfo> |
getQueuedRequests() |
org.kie.internal.executor.api.RequestInfo |
getRequestById(Long requestId) |
List<org.kie.internal.executor.api.RequestInfo> |
getRequestsByBusinessKey(String businessKey) |
List<org.kie.internal.executor.api.RequestInfo> |
getRequestsByStatus(List<org.kie.internal.executor.api.STATUS> statuses) |
int |
getRetries() |
List<org.kie.internal.executor.api.RequestInfo> |
getRunningRequests() |
int |
getThreadPoolSize() |
TimeUnit |
getTimeunit() |
void |
init() |
boolean |
isActive() |
void |
requeue(Long olderThan)
Moves
RequestInfo instances that are in running state longer than
given amount of time (in milliseconds) |
void |
requeueById(Long requestId)
Moves
RequestInfo instance with given request id that are in running state |
Long |
scheduleRequest(String commandName,
org.kie.internal.executor.api.CommandContext ctx) |
Long |
scheduleRequest(String commandId,
Date date,
org.kie.internal.executor.api.CommandContext ctx) |
void |
setAdminService(org.kie.internal.executor.api.ExecutorAdminService adminService) |
void |
setExecutor(org.kie.internal.executor.api.Executor executor) |
void |
setInterval(int waitTime) |
void |
setQueryService(org.kie.internal.executor.api.ExecutorQueryService queryService) |
void |
setRetries(int defaultNroOfRetries) |
void |
setThreadPoolSize(int nroOfThreads) |
void |
setTimeunit(TimeUnit timeunit) |
public ExecutorServiceImpl()
public ExecutorServiceImpl(org.kie.internal.executor.api.Executor executor)
public org.kie.internal.executor.api.Executor getExecutor()
public void setExecutor(org.kie.internal.executor.api.Executor executor)
public org.kie.internal.executor.api.ExecutorQueryService getQueryService()
public void setQueryService(org.kie.internal.executor.api.ExecutorQueryService queryService)
public org.kie.internal.executor.api.ExecutorAdminService getAdminService()
public void setAdminService(org.kie.internal.executor.api.ExecutorAdminService adminService)
public List<org.kie.internal.executor.api.RequestInfo> getFutureQueuedRequests()
getFutureQueuedRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getQueuedRequests()
getQueuedRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getCompletedRequests()
getCompletedRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getInErrorRequests()
getInErrorRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getCancelledRequests()
getCancelledRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.ErrorInfo> getAllErrors()
getAllErrors in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getAllRequests()
getAllRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getRequestsByStatus(List<org.kie.internal.executor.api.STATUS> statuses)
getRequestsByStatus in interface org.kie.internal.executor.api.ExecutorServicepublic int clearAllRequests()
clearAllRequests in interface org.kie.internal.executor.api.ExecutorServicepublic int clearAllErrors()
clearAllErrors in interface org.kie.internal.executor.api.ExecutorServicepublic Long scheduleRequest(String commandName, org.kie.internal.executor.api.CommandContext ctx)
scheduleRequest in interface org.kie.internal.executor.api.ExecutorServicepublic void cancelRequest(Long requestId)
cancelRequest in interface org.kie.internal.executor.api.ExecutorServicepublic void init()
init in interface org.kie.internal.executor.api.ExecutorServicepublic void destroy()
destroy in interface org.kie.internal.executor.api.ExecutorServicepublic boolean isActive()
isActive in interface org.kie.internal.executor.api.ExecutorServicepublic int getInterval()
getInterval in interface org.kie.internal.executor.api.ExecutorServicepublic void setInterval(int waitTime)
setInterval in interface org.kie.internal.executor.api.ExecutorServicepublic int getRetries()
getRetries in interface org.kie.internal.executor.api.ExecutorServicepublic void setRetries(int defaultNroOfRetries)
setRetries in interface org.kie.internal.executor.api.ExecutorServicepublic int getThreadPoolSize()
getThreadPoolSize in interface org.kie.internal.executor.api.ExecutorServicepublic void setThreadPoolSize(int nroOfThreads)
setThreadPoolSize in interface org.kie.internal.executor.api.ExecutorServicepublic TimeUnit getTimeunit()
getTimeunit in interface org.kie.internal.executor.api.ExecutorServicepublic void setTimeunit(TimeUnit timeunit)
setTimeunit in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getPendingRequests()
getPendingRequests in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getPendingRequestById(Long id)
getPendingRequestById in interface org.kie.internal.executor.api.ExecutorServicepublic Long scheduleRequest(String commandId, Date date, org.kie.internal.executor.api.CommandContext ctx)
scheduleRequest in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getRunningRequests()
getRunningRequests in interface org.kie.internal.executor.api.ExecutorServicepublic org.kie.internal.executor.api.RequestInfo getRequestById(Long requestId)
getRequestById in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.ErrorInfo> getErrorsByRequestId(Long requestId)
getErrorsByRequestId in interface org.kie.internal.executor.api.ExecutorServicepublic List<org.kie.internal.executor.api.RequestInfo> getRequestsByBusinessKey(String businessKey)
getRequestsByBusinessKey in interface org.kie.internal.executor.api.ExecutorServicepublic void requeue(Long olderThan)
RequeueAwareRequestInfo instances that are in running state longer than
given amount of time (in milliseconds)requeue in interface RequeueAwareolderThan - amount of time in milliseconds from current time stamppublic void requeueById(Long requestId)
RequeueAwareRequestInfo instance with given request id that are in running staterequeueById in interface RequeueAwarerequestId - request unique identifierCopyright © 2001–2015 JBoss by Red Hat. All rights reserved.