org.jbpm.executor.impl
Class ExecutorServiceImpl
java.lang.Object
org.jbpm.executor.impl.ExecutorServiceImpl
- All Implemented Interfaces:
- RequeueAware, 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
Fields inherited from interface org.kie.internal.executor.api.ExecutorService |
EXECUTOR_ID |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ExecutorServiceImpl
public ExecutorServiceImpl(org.kie.internal.executor.api.Executor executor)
getExecutor
public org.kie.internal.executor.api.Executor getExecutor()
setExecutor
public void setExecutor(org.kie.internal.executor.api.Executor executor)
getQueryService
public org.kie.internal.executor.api.ExecutorQueryService getQueryService()
setQueryService
public void setQueryService(org.kie.internal.executor.api.ExecutorQueryService queryService)
getAdminService
public org.kie.internal.executor.api.ExecutorAdminService getAdminService()
setAdminService
public void setAdminService(org.kie.internal.executor.api.ExecutorAdminService adminService)
getFutureQueuedRequests
public List<org.kie.internal.executor.api.RequestInfo> getFutureQueuedRequests()
- Specified by:
getFutureQueuedRequests
in interface org.kie.internal.executor.api.ExecutorService
getQueuedRequests
public List<org.kie.internal.executor.api.RequestInfo> getQueuedRequests()
- Specified by:
getQueuedRequests
in interface org.kie.internal.executor.api.ExecutorService
getCompletedRequests
public List<org.kie.internal.executor.api.RequestInfo> getCompletedRequests()
- Specified by:
getCompletedRequests
in interface org.kie.internal.executor.api.ExecutorService
getInErrorRequests
public List<org.kie.internal.executor.api.RequestInfo> getInErrorRequests()
- Specified by:
getInErrorRequests
in interface org.kie.internal.executor.api.ExecutorService
getCancelledRequests
public List<org.kie.internal.executor.api.RequestInfo> getCancelledRequests()
- Specified by:
getCancelledRequests
in interface org.kie.internal.executor.api.ExecutorService
getAllErrors
public List<org.kie.internal.executor.api.ErrorInfo> getAllErrors()
- Specified by:
getAllErrors
in interface org.kie.internal.executor.api.ExecutorService
getAllRequests
public List<org.kie.internal.executor.api.RequestInfo> getAllRequests()
- Specified by:
getAllRequests
in interface org.kie.internal.executor.api.ExecutorService
getRequestsByStatus
public List<org.kie.internal.executor.api.RequestInfo> getRequestsByStatus(List<org.kie.internal.executor.api.STATUS> statuses)
- Specified by:
getRequestsByStatus
in interface org.kie.internal.executor.api.ExecutorService
clearAllRequests
public int clearAllRequests()
- Specified by:
clearAllRequests
in interface org.kie.internal.executor.api.ExecutorService
clearAllErrors
public int clearAllErrors()
- Specified by:
clearAllErrors
in interface org.kie.internal.executor.api.ExecutorService
scheduleRequest
public Long scheduleRequest(String commandName,
org.kie.internal.executor.api.CommandContext ctx)
- Specified by:
scheduleRequest
in interface org.kie.internal.executor.api.ExecutorService
cancelRequest
public void cancelRequest(Long requestId)
- Specified by:
cancelRequest
in interface org.kie.internal.executor.api.ExecutorService
init
public void init()
- Specified by:
init
in interface org.kie.internal.executor.api.ExecutorService
destroy
public void destroy()
- Specified by:
destroy
in interface org.kie.internal.executor.api.ExecutorService
isActive
public boolean isActive()
- Specified by:
isActive
in interface org.kie.internal.executor.api.ExecutorService
getInterval
public int getInterval()
- Specified by:
getInterval
in interface org.kie.internal.executor.api.ExecutorService
setInterval
public void setInterval(int waitTime)
- Specified by:
setInterval
in interface org.kie.internal.executor.api.ExecutorService
getRetries
public int getRetries()
- Specified by:
getRetries
in interface org.kie.internal.executor.api.ExecutorService
setRetries
public void setRetries(int defaultNroOfRetries)
- Specified by:
setRetries
in interface org.kie.internal.executor.api.ExecutorService
getThreadPoolSize
public int getThreadPoolSize()
- Specified by:
getThreadPoolSize
in interface org.kie.internal.executor.api.ExecutorService
setThreadPoolSize
public void setThreadPoolSize(int nroOfThreads)
- Specified by:
setThreadPoolSize
in interface org.kie.internal.executor.api.ExecutorService
getTimeunit
public TimeUnit getTimeunit()
- Specified by:
getTimeunit
in interface org.kie.internal.executor.api.ExecutorService
setTimeunit
public void setTimeunit(TimeUnit timeunit)
- Specified by:
setTimeunit
in interface org.kie.internal.executor.api.ExecutorService
getPendingRequests
public List<org.kie.internal.executor.api.RequestInfo> getPendingRequests()
- Specified by:
getPendingRequests
in interface org.kie.internal.executor.api.ExecutorService
getPendingRequestById
public List<org.kie.internal.executor.api.RequestInfo> getPendingRequestById(Long id)
- Specified by:
getPendingRequestById
in interface org.kie.internal.executor.api.ExecutorService
scheduleRequest
public Long scheduleRequest(String commandId,
Date date,
org.kie.internal.executor.api.CommandContext ctx)
- Specified by:
scheduleRequest
in interface org.kie.internal.executor.api.ExecutorService
getRunningRequests
public List<org.kie.internal.executor.api.RequestInfo> getRunningRequests()
- Specified by:
getRunningRequests
in interface org.kie.internal.executor.api.ExecutorService
getRequestById
public org.kie.internal.executor.api.RequestInfo getRequestById(Long requestId)
- Specified by:
getRequestById
in interface org.kie.internal.executor.api.ExecutorService
getErrorsByRequestId
public List<org.kie.internal.executor.api.ErrorInfo> getErrorsByRequestId(Long requestId)
- Specified by:
getErrorsByRequestId
in interface org.kie.internal.executor.api.ExecutorService
getRequestsByBusinessKey
public List<org.kie.internal.executor.api.RequestInfo> getRequestsByBusinessKey(String businessKey)
- Specified by:
getRequestsByBusinessKey
in interface org.kie.internal.executor.api.ExecutorService
requeue
public void requeue(Long olderThan)
- Description copied from interface:
RequeueAware
- Moves
RequestInfo
instances that are in running state longer than
given amount of time (in milliseconds)
- Specified by:
requeue
in interface RequeueAware
- Parameters:
olderThan
- amount of time in milliseconds from current time stamp
requeueById
public void requeueById(Long requestId)
- Description copied from interface:
RequeueAware
- Moves
RequestInfo
instance with given request id that are in running state
- Specified by:
requeueById
in interface RequeueAware
- Parameters:
requestId
- request unique identifier
Copyright © 2001-2014 JBoss by Red Hat. All Rights Reserved.