Class AbstractAvailableJobsExecutor

  • Direct Known Subclasses:
    AvailableJobsExecutor, JmsAvailableJobsExecutor

    public abstract class AbstractAvailableJobsExecutor
    extends Object
    Heart of the executor component - executes the actual tasks. Handles retries and error management. Based on results of execution notifies defined callbacks about the execution results.
    • Field Detail

      • retries

        protected int retries
      • queryService

        protected org.kie.api.executor.ExecutorQueryService queryService
      • executorStoreService

        protected org.kie.api.executor.ExecutorStoreService executorStoreService
      • executor

        protected org.kie.api.executor.Executor executor
    • Constructor Detail

      • AbstractAvailableJobsExecutor

        public AbstractAvailableJobsExecutor()
    • Method Detail

      • setQueryService

        public void setQueryService​(org.kie.api.executor.ExecutorQueryService queryService)
      • setClassCacheManager

        public void setClassCacheManager​(ClassCacheManager classCacheManager)
      • setExecutorStoreService

        public void setExecutorStoreService​(org.kie.api.executor.ExecutorStoreService executorStoreService)
      • setExecutor

        public void setExecutor​(org.kie.api.executor.Executor executor)
      • executeGivenJob

        public void executeGivenJob​(RequestInfo request)
      • addContextData

        public void addContextData​(String name,
                                   Object data)
      • handleException

        protected boolean handleException​(RequestInfo request,
                                          Throwable e,
                                          org.kie.api.executor.CommandContext ctx,
                                          List<org.kie.api.executor.CommandCallback> callbacks)
      • handleCompletion

        protected void handleCompletion​(boolean processReoccurring,
                                        org.kie.api.executor.Command cmd,
                                        org.kie.api.executor.CommandContext ctx)
      • updateProcessInfoInContext

        protected void updateProcessInfoInContext​(RequestInfo requestInfo,
                                                  org.kie.api.executor.CommandContext ctx)