Package org.jbpm.executor.impl
Class ExecutorServiceImpl
- java.lang.Object
-
- org.jbpm.executor.impl.ExecutorServiceImpl
-
- All Implemented Interfaces:
RequeueAware
,org.kie.api.executor.ExecutorService
,org.kie.internal.executor.api.ExecutorService
public class ExecutorServiceImpl extends Object implements org.kie.internal.executor.api.ExecutorService, RequeueAware
Entry point of the executor component. Application should always talk via this service to ensure all internals are properly initialized
-
-
Constructor Summary
Constructors Constructor Description ExecutorServiceImpl()
ExecutorServiceImpl(org.kie.api.executor.Executor executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
MovesRequestInfo
instances that are in running state longer than given amount of time (time unit depends on theorg.kie.executor.timeunit
system property)void
requeueById(Long requestId)
MovesRequestInfo
instance with given request id that are in running stateLong
scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
Long
scheduleRequest(String commandName, 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)
-
-
-
Method Detail
-
getEventSupport
public ExecutorEventSupport getEventSupport()
-
setEventSupport
public void setEventSupport(ExecutorEventSupport eventSupport)
-
getExecutor
public org.kie.api.executor.Executor getExecutor()
-
setExecutor
public void setExecutor(org.kie.api.executor.Executor executor)
-
getQueryService
public org.kie.api.executor.ExecutorQueryService getQueryService()
-
setQueryService
public void setQueryService(org.kie.api.executor.ExecutorQueryService queryService)
-
getAdminService
public org.kie.api.executor.ExecutorAdminService getAdminService()
-
setAdminService
public void setAdminService(org.kie.api.executor.ExecutorAdminService adminService)
-
getFutureQueuedRequests
public List<org.kie.api.executor.RequestInfo> getFutureQueuedRequests()
-
getQueuedRequests
public List<org.kie.api.executor.RequestInfo> getQueuedRequests()
-
getCompletedRequests
public List<org.kie.api.executor.RequestInfo> getCompletedRequests()
-
getInErrorRequests
public List<org.kie.api.executor.RequestInfo> getInErrorRequests()
-
getCancelledRequests
public List<org.kie.api.executor.RequestInfo> getCancelledRequests()
-
getAllErrors
public List<org.kie.api.executor.ErrorInfo> getAllErrors()
-
getAllRequests
public List<org.kie.api.executor.RequestInfo> getAllRequests()
-
getRequestsByStatus
public List<org.kie.api.executor.RequestInfo> getRequestsByStatus(List<org.kie.api.executor.STATUS> statuses)
-
clearAllRequests
public int clearAllRequests()
- Specified by:
clearAllRequests
in interfaceorg.kie.api.executor.ExecutorService
-
clearAllErrors
public int clearAllErrors()
- Specified by:
clearAllErrors
in interfaceorg.kie.api.executor.ExecutorService
-
scheduleRequest
public Long scheduleRequest(String commandName, org.kie.api.executor.CommandContext ctx)
- Specified by:
scheduleRequest
in interfaceorg.kie.api.executor.ExecutorService
-
cancelRequest
public void cancelRequest(Long requestId)
- Specified by:
cancelRequest
in interfaceorg.kie.api.executor.ExecutorService
-
init
public void init()
- Specified by:
init
in interfaceorg.kie.api.executor.ExecutorService
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceorg.kie.api.executor.ExecutorService
-
isActive
public boolean isActive()
- Specified by:
isActive
in interfaceorg.kie.api.executor.ExecutorService
-
getInterval
public int getInterval()
- Specified by:
getInterval
in interfaceorg.kie.api.executor.ExecutorService
-
setInterval
public void setInterval(int waitTime)
- Specified by:
setInterval
in interfaceorg.kie.api.executor.ExecutorService
-
getRetries
public int getRetries()
- Specified by:
getRetries
in interfaceorg.kie.api.executor.ExecutorService
-
setRetries
public void setRetries(int defaultNroOfRetries)
- Specified by:
setRetries
in interfaceorg.kie.api.executor.ExecutorService
-
getThreadPoolSize
public int getThreadPoolSize()
- Specified by:
getThreadPoolSize
in interfaceorg.kie.api.executor.ExecutorService
-
setThreadPoolSize
public void setThreadPoolSize(int nroOfThreads)
- Specified by:
setThreadPoolSize
in interfaceorg.kie.api.executor.ExecutorService
-
getTimeunit
public TimeUnit getTimeunit()
- Specified by:
getTimeunit
in interfaceorg.kie.api.executor.ExecutorService
-
setTimeunit
public void setTimeunit(TimeUnit timeunit)
- Specified by:
setTimeunit
in interfaceorg.kie.api.executor.ExecutorService
-
getPendingRequests
public List<org.kie.api.executor.RequestInfo> getPendingRequests()
-
getPendingRequestById
public List<org.kie.api.executor.RequestInfo> getPendingRequestById(Long id)
- Specified by:
getPendingRequestById
in interfaceorg.kie.api.executor.ExecutorService
-
scheduleRequest
public Long scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
- Specified by:
scheduleRequest
in interfaceorg.kie.api.executor.ExecutorService
-
getRunningRequests
public List<org.kie.api.executor.RequestInfo> getRunningRequests()
-
getRequestById
public org.kie.api.executor.RequestInfo getRequestById(Long requestId)
- Specified by:
getRequestById
in interfaceorg.kie.api.executor.ExecutorService
-
getErrorsByRequestId
public List<org.kie.api.executor.ErrorInfo> getErrorsByRequestId(Long requestId)
- Specified by:
getErrorsByRequestId
in interfaceorg.kie.api.executor.ExecutorService
-
getRequestsByBusinessKey
public List<org.kie.api.executor.RequestInfo> getRequestsByBusinessKey(String businessKey, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByBusinessKey
in interfaceorg.kie.api.executor.ExecutorService
-
getRequestsByCommand
public List<org.kie.api.executor.RequestInfo> getRequestsByCommand(String command, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByCommand
in interfaceorg.kie.api.executor.ExecutorService
-
requeue
public void requeue(Long olderThan)
Description copied from interface:RequeueAware
MovesRequestInfo
instances that are in running state longer than given amount of time (time unit depends on theorg.kie.executor.timeunit
system property)- Specified by:
requeue
in interfaceRequeueAware
- Parameters:
olderThan
- amount of time from current time stamp
-
requeueById
public void requeueById(Long requestId)
Description copied from interface:RequeueAware
MovesRequestInfo
instance with given request id that are in running state- Specified by:
requeueById
in interfaceRequeueAware
- Parameters:
requestId
- request unique identifier
-
getQueuedRequests
public List<org.kie.api.executor.RequestInfo> getQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getQueuedRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getCompletedRequests
public List<org.kie.api.executor.RequestInfo> getCompletedRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getCompletedRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getInErrorRequests
public List<org.kie.api.executor.RequestInfo> getInErrorRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getInErrorRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getCancelledRequests
public List<org.kie.api.executor.RequestInfo> getCancelledRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getCancelledRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getAllErrors
public List<org.kie.api.executor.ErrorInfo> getAllErrors(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getAllErrors
in interfaceorg.kie.api.executor.ExecutorService
-
getAllRequests
public List<org.kie.api.executor.RequestInfo> getAllRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getAllRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getRequestsByStatus
public List<org.kie.api.executor.RequestInfo> getRequestsByStatus(List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByStatus
in interfaceorg.kie.api.executor.ExecutorService
-
getPendingRequests
public List<org.kie.api.executor.RequestInfo> getPendingRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getPendingRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getRunningRequests
public List<org.kie.api.executor.RequestInfo> getRunningRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRunningRequests
in interfaceorg.kie.api.executor.ExecutorService
-
getFutureQueuedRequests
public List<org.kie.api.executor.RequestInfo> getFutureQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getFutureQueuedRequests
in interfaceorg.kie.api.executor.ExecutorService
-
addAsyncJobListener
public void addAsyncJobListener(AsynchronousJobListener listener)
-
removeAsyncJobListener
public void removeAsyncJobListener(AsynchronousJobListener listener)
-
getAsyncJobListeners
public List<AsynchronousJobListener> getAsyncJobListeners()
-
getRequestsByBusinessKey
public List<org.kie.api.executor.RequestInfo> getRequestsByBusinessKey(String businessKey, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByBusinessKey
in interfaceorg.kie.api.executor.ExecutorService
-
getRequestsByCommand
public List<org.kie.api.executor.RequestInfo> getRequestsByCommand(String command, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByCommand
in interfaceorg.kie.api.executor.ExecutorService
-
getRequestsByDeployment
public List<org.kie.api.executor.RequestInfo> getRequestsByDeployment(String deploymentId, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByDeployment
in interfaceorg.kie.api.executor.ExecutorService
-
getRequestsByProcessInstance
public List<org.kie.api.executor.RequestInfo> getRequestsByProcessInstance(Long processInstanceId, List<org.kie.api.executor.STATUS> statuses, org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRequestsByProcessInstance
in interfaceorg.kie.api.executor.ExecutorService
-
-