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 (in milliseconds) |
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.ExecutorService
public int clearAllErrors()
clearAllErrors
in interface org.kie.api.executor.ExecutorService
public Long scheduleRequest(String commandName, org.kie.api.executor.CommandContext ctx)
scheduleRequest
in interface org.kie.api.executor.ExecutorService
public void cancelRequest(Long requestId)
cancelRequest
in interface org.kie.api.executor.ExecutorService
public void init()
init
in interface org.kie.api.executor.ExecutorService
public void destroy()
destroy
in interface org.kie.api.executor.ExecutorService
public boolean isActive()
isActive
in interface org.kie.api.executor.ExecutorService
public int getInterval()
getInterval
in interface org.kie.api.executor.ExecutorService
public void setInterval(int waitTime)
setInterval
in interface org.kie.api.executor.ExecutorService
public int getRetries()
getRetries
in interface org.kie.api.executor.ExecutorService
public void setRetries(int defaultNroOfRetries)
setRetries
in interface org.kie.api.executor.ExecutorService
public int getThreadPoolSize()
getThreadPoolSize
in interface org.kie.api.executor.ExecutorService
public void setThreadPoolSize(int nroOfThreads)
setThreadPoolSize
in interface org.kie.api.executor.ExecutorService
public TimeUnit getTimeunit()
getTimeunit
in interface org.kie.api.executor.ExecutorService
public void setTimeunit(TimeUnit timeunit)
setTimeunit
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getPendingRequests()
public List<org.kie.api.executor.RequestInfo> getPendingRequestById(Long id)
getPendingRequestById
in interface org.kie.api.executor.ExecutorService
public Long scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
scheduleRequest
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getRunningRequests()
public org.kie.api.executor.RequestInfo getRequestById(Long requestId)
getRequestById
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.ErrorInfo> getErrorsByRequestId(Long requestId)
getErrorsByRequestId
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getRequestsByBusinessKey(String businessKey, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByBusinessKey
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getRequestsByCommand(String command, org.kie.api.runtime.query.QueryContext queryContext)
getRequestsByCommand
in interface org.kie.api.executor.ExecutorService
public void requeue(Long olderThan)
RequeueAware
RequestInfo
instances that are in running state longer than
given amount of time (in milliseconds)requeue
in interface RequeueAware
olderThan
- amount of time in milliseconds from current time stamppublic void requeueById(Long requestId)
RequeueAware
RequestInfo
instance with given request id that are in running staterequeueById
in interface RequeueAware
requestId
- request unique identifierpublic List<org.kie.api.executor.RequestInfo> getQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
getQueuedRequests
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getCompletedRequests(org.kie.api.runtime.query.QueryContext queryContext)
getCompletedRequests
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getInErrorRequests(org.kie.api.runtime.query.QueryContext queryContext)
getInErrorRequests
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getCancelledRequests(org.kie.api.runtime.query.QueryContext queryContext)
getCancelledRequests
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.ErrorInfo> getAllErrors(org.kie.api.runtime.query.QueryContext queryContext)
getAllErrors
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getAllRequests(org.kie.api.runtime.query.QueryContext queryContext)
getAllRequests
in interface org.kie.api.executor.ExecutorService
public 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.ExecutorService
public List<org.kie.api.executor.RequestInfo> getPendingRequests(org.kie.api.runtime.query.QueryContext queryContext)
getPendingRequests
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getRunningRequests(org.kie.api.runtime.query.QueryContext queryContext)
getRunningRequests
in interface org.kie.api.executor.ExecutorService
public List<org.kie.api.executor.RequestInfo> getFutureQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
getFutureQueuedRequests
in interface org.kie.api.executor.ExecutorService
public 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.ExecutorService
public 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.ExecutorService
public 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.ExecutorService
public 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.ExecutorService
Copyright © 2001–2018 JBoss by Red Hat. All rights reserved.