jBPM distribution 6.0.0.CR4

org.jbpm.executor.impl
Class ExecutorImpl

java.lang.Object
  extended by org.jbpm.executor.impl.ExecutorImpl
All Implemented Interfaces:
org.kie.internal.executor.api.Executor

@ApplicationScoped
public class ExecutorImpl
extends Object
implements org.kie.internal.executor.api.Executor

Default implementation of the Executor that is baced by ScheduledExecutorService for background task execution. It can be configured for following:

Additionally executor can be disable to not start at all when system property org.kie.executor.disabled is set to true


Constructor Summary
ExecutorImpl()
           
 
Method Summary
 void cancelRequest(Long requestId)
          
 void destroy()
          
 int getInterval()
          
 int getRetries()
          
 int getThreadPoolSize()
          
 void init()
          
 Long scheduleRequest(String commandId, org.kie.internal.executor.api.CommandContext ctx)
          
 Long scheduleRequest(String commandId, Date date, org.kie.internal.executor.api.CommandContext ctx)
          
 void setClassCacheManager(ClassCacheManager classCacheManager)
           
 void setExecutorRunnable(ExecutorRunnable runnableTask)
           
 void setInterval(int interval)
          
 void setPm(JbpmServicesPersistenceManager pm)
           
 void setQueryService(org.kie.internal.executor.api.ExecutorQueryService queryService)
           
 void setRetries(int retries)
          
 void setThreadPoolSize(int threadPoolSize)
          
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ExecutorImpl

public ExecutorImpl()
Method Detail

setPm

public void setPm(JbpmServicesPersistenceManager pm)

setExecutorRunnable

public void setExecutorRunnable(ExecutorRunnable runnableTask)

setQueryService

public void setQueryService(org.kie.internal.executor.api.ExecutorQueryService queryService)

setClassCacheManager

public void setClassCacheManager(ClassCacheManager classCacheManager)

getInterval

public int getInterval()

Specified by:
getInterval in interface org.kie.internal.executor.api.Executor

setInterval

public void setInterval(int interval)

Specified by:
setInterval in interface org.kie.internal.executor.api.Executor

getRetries

public int getRetries()

Specified by:
getRetries in interface org.kie.internal.executor.api.Executor

setRetries

public void setRetries(int retries)

Specified by:
setRetries in interface org.kie.internal.executor.api.Executor

getThreadPoolSize

public int getThreadPoolSize()

Specified by:
getThreadPoolSize in interface org.kie.internal.executor.api.Executor

setThreadPoolSize

public void setThreadPoolSize(int threadPoolSize)

Specified by:
setThreadPoolSize in interface org.kie.internal.executor.api.Executor

init

public void init()

Specified by:
init in interface org.kie.internal.executor.api.Executor

destroy

public void destroy()

Specified by:
destroy in interface org.kie.internal.executor.api.Executor

scheduleRequest

public Long scheduleRequest(String commandId,
                            org.kie.internal.executor.api.CommandContext ctx)

Specified by:
scheduleRequest in interface org.kie.internal.executor.api.Executor

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.Executor

cancelRequest

public void cancelRequest(Long requestId)

Specified by:
cancelRequest in interface org.kie.internal.executor.api.Executor

jBPM distribution 6.0.0.CR4

Copyright © 2001-2013 JBoss by Red Hat. All Rights Reserved.