public class JcaWorkManagerExecutorService extends Object implements javax.resource.Referenceable, ExecutorService
AbstractPlatformJobExecutor
implementation delegating to a JCA WorkManager
.Modifier and Type | Field and Description |
---|---|
protected JcaExecutorServiceConnector |
ra |
protected Reference |
reference |
static int |
START_WORK_TIMEOUT |
protected javax.resource.spi.work.WorkManager |
workManager |
Constructor and Description |
---|
JcaWorkManagerExecutorService(JcaExecutorServiceConnector connector,
javax.resource.spi.work.WorkManager workManager) |
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.
|
JcaExecutorServiceConnector |
getPlatformJobExecutorConnector() |
Reference |
getReference() |
javax.resource.spi.work.WorkManager |
getWorkManager() |
boolean |
schedule(Runnable runnable,
boolean isLongRunning)
Passes a
Runnable to the runtime container for execution. |
protected boolean |
scheduleLongRunning(Runnable runnable) |
void |
setReference(Reference reference) |
public static int START_WORK_TIMEOUT
protected final JcaExecutorServiceConnector ra
protected javax.resource.spi.work.WorkManager workManager
protected Reference reference
public JcaWorkManagerExecutorService(JcaExecutorServiceConnector connector, javax.resource.spi.work.WorkManager workManager)
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 scheduleLongRunning(Runnable runnable)
protected boolean executeShortRunning(Runnable runnable)
public Runnable getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine)
ExecutorService
Returns a runnable to be used for executing Jobs.
getExecuteJobsRunnable
in interface ExecutorService
public Reference getReference() throws NamingException
getReference
in interface Referenceable
NamingException
public void setReference(Reference reference)
public javax.resource.spi.work.WorkManager getWorkManager()
public JcaExecutorServiceConnector getPlatformJobExecutorConnector()
Copyright © 2017. All rights reserved.