public class CommonJWorkManagerExecutorService extends Object implements ExecutorService
AbstractPlatformJobExecutor
implementation delegating to a CommonJ WorkManager
.Modifier and Type | Field and Description |
---|---|
protected String |
commonJWorkManagerName |
protected JcaExecutorServiceConnector |
ra |
protected commonj.work.WorkManager |
workManager |
Constructor and Description |
---|
CommonJWorkManagerExecutorService(JcaExecutorServiceConnector ra,
String commonJWorkManagerName) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
executeShortRunning(Runnable runnable) |
Runnable |
getExecuteJobsRunnable(List<String> jobIds,
ProcessEngineImpl processEngine)
Returns a runnable to be used for executing Jobs.
|
commonj.work.WorkManager |
getWorkManager() |
protected commonj.work.WorkManager |
lookupWorkMananger() |
boolean |
schedule(Runnable runnable,
boolean isLongRunning)
Passes a
Runnable to the runtime container for execution. |
protected boolean |
scheduleLongRunning(Runnable acquisitionRunnable) |
protected commonj.work.WorkManager workManager
protected JcaExecutorServiceConnector ra
protected String commonJWorkManagerName
public CommonJWorkManagerExecutorService(JcaExecutorServiceConnector ra, String commonJWorkManagerName)
protected commonj.work.WorkManager lookupWorkMananger()
public boolean schedule(Runnable runnable, boolean isLongRunning)
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.
schedule
in interface ExecutorService
runnable
- the Runnable
to be executed.isLongRunning
- indicates whether the runnable is a daemon.protected boolean executeShortRunning(Runnable runnable)
protected boolean scheduleLongRunning(Runnable acquisitionRunnable)
public Runnable getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)
ExecutorService
Returns a runnable to be used for executing Jobs.
getExecuteJobsRunnable
in interface ExecutorService
public commonj.work.WorkManager getWorkManager()
Copyright © 2017. All rights reserved.