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 voidaddAsyncJobListener(AsynchronousJobListener listener)voidcancelRequest(Long requestId)intclearAllErrors()intclearAllRequests()voiddestroy()org.kie.api.executor.ExecutorAdminServicegetAdminService()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)ExecutorEventSupportgetEventSupport()org.kie.api.executor.ExecutorgetExecutor()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)intgetInterval()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.ExecutorQueryServicegetQueryService()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.RequestInfogetRequestById(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)intgetRetries()List<org.kie.api.executor.RequestInfo>getRunningRequests()List<org.kie.api.executor.RequestInfo>getRunningRequests(org.kie.api.runtime.query.QueryContext queryContext)intgetThreadPoolSize()TimeUnitgetTimeunit()voidinit()booleanisActive()voidremoveAsyncJobListener(AsynchronousJobListener listener)voidrequeue(Long olderThan)MovesRequestInfoinstances that are in running state longer than given amount of time (time unit depends on theorg.kie.executor.timeunitsystem property)voidrequeueById(Long requestId)MovesRequestInfoinstance with given request id that are in running stateLongscheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)LongscheduleRequest(String commandName, org.kie.api.executor.CommandContext ctx)voidsetAdminService(org.kie.api.executor.ExecutorAdminService adminService)voidsetEventSupport(ExecutorEventSupport eventSupport)voidsetExecutor(org.kie.api.executor.Executor executor)voidsetInterval(int waitTime)voidsetQueryService(org.kie.api.executor.ExecutorQueryService queryService)voidsetRetries(int defaultNroOfRetries)voidsetThreadPoolSize(int nroOfThreads)voidsetTimeunit(TimeUnit timeunit)voidupdateRequestData(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:
clearAllRequestsin interfaceorg.kie.api.executor.ExecutorService
-
clearAllErrors
public int clearAllErrors()
- Specified by:
clearAllErrorsin interfaceorg.kie.api.executor.ExecutorService
-
scheduleRequest
public Long scheduleRequest(String commandName, org.kie.api.executor.CommandContext ctx)
- Specified by:
scheduleRequestin interfaceorg.kie.api.executor.ExecutorService
-
cancelRequest
public void cancelRequest(Long requestId)
- Specified by:
cancelRequestin interfaceorg.kie.api.executor.ExecutorService
-
init
public void init()
- Specified by:
initin interfaceorg.kie.api.executor.ExecutorService
-
destroy
public void destroy()
- Specified by:
destroyin interfaceorg.kie.api.executor.ExecutorService
-
isActive
public boolean isActive()
- Specified by:
isActivein interfaceorg.kie.api.executor.ExecutorService
-
getInterval
public int getInterval()
- Specified by:
getIntervalin interfaceorg.kie.api.executor.ExecutorService
-
setInterval
public void setInterval(int waitTime)
- Specified by:
setIntervalin interfaceorg.kie.api.executor.ExecutorService
-
getRetries
public int getRetries()
- Specified by:
getRetriesin interfaceorg.kie.api.executor.ExecutorService
-
setRetries
public void setRetries(int defaultNroOfRetries)
- Specified by:
setRetriesin interfaceorg.kie.api.executor.ExecutorService
-
getThreadPoolSize
public int getThreadPoolSize()
- Specified by:
getThreadPoolSizein interfaceorg.kie.api.executor.ExecutorService
-
setThreadPoolSize
public void setThreadPoolSize(int nroOfThreads)
- Specified by:
setThreadPoolSizein interfaceorg.kie.api.executor.ExecutorService
-
getTimeunit
public TimeUnit getTimeunit()
- Specified by:
getTimeunitin interfaceorg.kie.api.executor.ExecutorService
-
setTimeunit
public void setTimeunit(TimeUnit timeunit)
- Specified by:
setTimeunitin 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:
getPendingRequestByIdin interfaceorg.kie.api.executor.ExecutorService
-
scheduleRequest
public Long scheduleRequest(String commandId, Date date, org.kie.api.executor.CommandContext ctx)
- Specified by:
scheduleRequestin 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:
getRequestByIdin interfaceorg.kie.api.executor.ExecutorService
-
getErrorsByRequestId
public List<org.kie.api.executor.ErrorInfo> getErrorsByRequestId(Long requestId)
- Specified by:
getErrorsByRequestIdin 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:
getRequestsByBusinessKeyin 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:
getRequestsByCommandin interfaceorg.kie.api.executor.ExecutorService
-
requeue
public void requeue(Long olderThan)
Description copied from interface:RequeueAwareMovesRequestInfoinstances that are in running state longer than given amount of time (time unit depends on theorg.kie.executor.timeunitsystem property)- Specified by:
requeuein interfaceRequeueAware- Parameters:
olderThan- amount of time from current time stamp
-
requeueById
public void requeueById(Long requestId)
Description copied from interface:RequeueAwareMovesRequestInfoinstance with given request id that are in running state- Specified by:
requeueByIdin interfaceRequeueAware- Parameters:
requestId- request unique identifier
-
getQueuedRequests
public List<org.kie.api.executor.RequestInfo> getQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getQueuedRequestsin interfaceorg.kie.api.executor.ExecutorService
-
getCompletedRequests
public List<org.kie.api.executor.RequestInfo> getCompletedRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getCompletedRequestsin interfaceorg.kie.api.executor.ExecutorService
-
getInErrorRequests
public List<org.kie.api.executor.RequestInfo> getInErrorRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getInErrorRequestsin interfaceorg.kie.api.executor.ExecutorService
-
getCancelledRequests
public List<org.kie.api.executor.RequestInfo> getCancelledRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getCancelledRequestsin interfaceorg.kie.api.executor.ExecutorService
-
getAllErrors
public List<org.kie.api.executor.ErrorInfo> getAllErrors(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getAllErrorsin interfaceorg.kie.api.executor.ExecutorService
-
getAllRequests
public List<org.kie.api.executor.RequestInfo> getAllRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getAllRequestsin 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:
getRequestsByStatusin interfaceorg.kie.api.executor.ExecutorService
-
getPendingRequests
public List<org.kie.api.executor.RequestInfo> getPendingRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getPendingRequestsin interfaceorg.kie.api.executor.ExecutorService
-
getRunningRequests
public List<org.kie.api.executor.RequestInfo> getRunningRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getRunningRequestsin interfaceorg.kie.api.executor.ExecutorService
-
getFutureQueuedRequests
public List<org.kie.api.executor.RequestInfo> getFutureQueuedRequests(org.kie.api.runtime.query.QueryContext queryContext)
- Specified by:
getFutureQueuedRequestsin 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:
getRequestsByBusinessKeyin 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:
getRequestsByCommandin 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:
getRequestsByDeploymentin 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:
getRequestsByProcessInstancein interfaceorg.kie.api.executor.ExecutorService
-
-