public class ExecutorServiceImpl extends Object implements org.kie.internal.executor.api.ExecutorService
Constructor and Description |
---|
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() |
void |
init() |
boolean |
isActive() |
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) |
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.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getQueuedRequests()
getQueuedRequests
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getCompletedRequests()
getCompletedRequests
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getInErrorRequests()
getInErrorRequests
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getCancelledRequests()
getCancelledRequests
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.ErrorInfo> getAllErrors()
getAllErrors
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getAllRequests()
getAllRequests
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getRequestsByStatus(List<org.kie.internal.executor.api.STATUS> statuses)
getRequestsByStatus
in interface org.kie.internal.executor.api.ExecutorService
public int clearAllRequests()
clearAllRequests
in interface org.kie.internal.executor.api.ExecutorService
public int clearAllErrors()
clearAllErrors
in interface org.kie.internal.executor.api.ExecutorService
public Long scheduleRequest(String commandName, org.kie.internal.executor.api.CommandContext ctx)
scheduleRequest
in interface org.kie.internal.executor.api.ExecutorService
public void cancelRequest(Long requestId)
cancelRequest
in interface org.kie.internal.executor.api.ExecutorService
public void init()
init
in interface org.kie.internal.executor.api.ExecutorService
public void destroy()
destroy
in interface org.kie.internal.executor.api.ExecutorService
public boolean isActive()
isActive
in interface org.kie.internal.executor.api.ExecutorService
public int getInterval()
getInterval
in interface org.kie.internal.executor.api.ExecutorService
public void setInterval(int waitTime)
setInterval
in interface org.kie.internal.executor.api.ExecutorService
public int getRetries()
getRetries
in interface org.kie.internal.executor.api.ExecutorService
public void setRetries(int defaultNroOfRetries)
setRetries
in interface org.kie.internal.executor.api.ExecutorService
public int getThreadPoolSize()
getThreadPoolSize
in interface org.kie.internal.executor.api.ExecutorService
public void setThreadPoolSize(int nroOfThreads)
setThreadPoolSize
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getPendingRequests()
getPendingRequests
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getPendingRequestById(Long id)
getPendingRequestById
in interface org.kie.internal.executor.api.ExecutorService
public Long scheduleRequest(String commandId, Date date, org.kie.internal.executor.api.CommandContext ctx)
scheduleRequest
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.RequestInfo> getRunningRequests()
getRunningRequests
in interface org.kie.internal.executor.api.ExecutorService
public org.kie.internal.executor.api.RequestInfo getRequestById(Long requestId)
getRequestById
in interface org.kie.internal.executor.api.ExecutorService
public List<org.kie.internal.executor.api.ErrorInfo> getErrorsByRequestId(Long requestId)
getErrorsByRequestId
in interface org.kie.internal.executor.api.ExecutorService
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.