jBPM :: Distribution 6.2.0-SNAPSHOT

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

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()
          
 TimeUnit getTimeunit()
          
 void init()
          
 void init(ThreadFactory threadFactory)
           
 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 setExecutorStoreService(org.kie.internal.executor.api.ExecutorStoreService executorStoreService)
           
 void setInterval(int interval)
          
 void setRetries(int retries)
          
 void setThreadPoolSize(int threadPoolSize)
          
 void setTimeunit(TimeUnit timeunit)
          
 
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

setExecutorStoreService

public void setExecutorStoreService(org.kie.internal.executor.api.ExecutorStoreService executorStoreService)

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

getTimeunit

public TimeUnit getTimeunit()

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

setTimeunit

public void setTimeunit(TimeUnit timeunit)

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

init

public void init()

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

init

public void init(ThreadFactory threadFactory)

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.2.0-SNAPSHOT

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