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 theExecutorService
as Stateless Bean.- Author:
- Daniel Meyer
-
-
Field Summary
Fields Modifier and Type Field Description protected JcaExecutorServiceConnection
executorConnection
protected JcaExecutorServiceConnectionFactory
executorConnectionFactory
-
Constructor Summary
Constructors Constructor Description ExecutorServiceBean()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 aRunnable
to the runtime container for execution.
-
-
-
Field Detail
-
executorConnectionFactory
protected JcaExecutorServiceConnectionFactory executorConnectionFactory
-
executorConnection
protected JcaExecutorServiceConnection executorConnection
-
-
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 interfaceExecutorService
- Parameters:
runnable
- theRunnable
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 interfaceExecutorService
- Returns:
-
-