org.camunda.bpm.container.impl.ejb

Class ExecutorServiceBean

java.lang.Object

org.camunda.bpm.container.impl.ejb.ExecutorServiceBean

All Implemented Interfaces:

ExecutorService

public class ExecutorServiceBean
extends Object
implements ExecutorService

Bean exposing the JCA implementation of the ExecutorService as Stateless Bean.

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
protected JcaExecutorServiceConnection	executorConnection
protected JcaExecutorServiceConnectionFactory	executorConnectionFactory

Constructor Summary

Constructors

Constructor and Description
ExecutorServiceBean()

Method Summary

Modifier and Type	Method and Description
protected void	closeConnection()
Runnable	getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine) Returns a runnable to be used for executing Jobs.
protected void	openConnection()
boolean	schedule(Runnable runnable, boolean isLongRunning) Passes a Runnable to the runtime container for execution.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

executorConnectionFactory

protected JcaExecutorServiceConnectionFactory executorConnectionFactory

executorConnection

protected JcaExecutorServiceConnection executorConnection

Constructor Detail

ExecutorServiceBean

public ExecutorServiceBean()

Method Detail

openConnection

@PostConstruct
protected void openConnection()

closeConnection

@PreDestroy
protected void closeConnection()

schedule

public boolean schedule(Runnable runnable,
                        boolean isLongRunning)

Description copied from interface: ExecutorService

Passes a Runnable to the runtime container for execution. Some runtime containers (like a Java EE container offer container provided infrastructure for executing background work (such as a JCA WorkManager). This method allows the process engine to take advantage of container infrastructure for doing background work.

Specified by:

schedule in interface ExecutorService

Parameters:

runnable - the Runnable to be executed.

isLongRunning - indicates whether the runnable is a daemon.

Returns:

true if the runnable could be successfully scheduled for execution. 'false' otherwise.

getExecuteJobsRunnable

public Runnable getExecuteJobsRunnable(List<String> jobIds,
                                       ProcessEngineImpl processEngine)

Description copied from interface: ExecutorService

Returns a runnable to be used for executing Jobs.

Specified by:

getExecuteJobsRunnable in interface ExecutorService

Returns: