Package org.operaton.bpm.container.impl.threading.ra

Class JcaWorkManagerExecutorService

java.lang.Object

org.operaton.bpm.container.impl.threading.ra.JcaWorkManagerExecutorService

All Implemented Interfaces:

jakarta.resource.Referenceable, Referenceable, ExecutorService

public class JcaWorkManagerExecutorService
extends Object
implements jakarta.resource.Referenceable, ExecutorService

invalid reference

AbstractPlatformJobExecutor

implementation delegating to a JCA WorkManager.

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected final JcaExecutorServiceConnector	ra
protected Reference	reference
static final int	START_WORK_TIMEOUT
protected jakarta.resource.spi.work.WorkManager	workManager

Constructor Summary

Constructors

Constructor	Description
JcaWorkManagerExecutorService(JcaExecutorServiceConnector connector, jakarta.resource.spi.work.WorkManager workManager)

Method Summary

Modifier and Type	Method	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()
jakarta.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)

Methods inherited from class java.lang.Object

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

Field Details

START_WORK_TIMEOUT

public static final int START_WORK_TIMEOUT

See Also:

• Constant Field Values

ra

protected final JcaExecutorServiceConnector ra

workManager

protected jakarta.resource.spi.work.WorkManager workManager

reference

protected Reference reference

Constructor Details

JcaWorkManagerExecutorService

public JcaWorkManagerExecutorService(JcaExecutorServiceConnector connector,
 jakarta.resource.spi.work.WorkManager workManager)

Method Details

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.

scheduleLongRunning

protected boolean scheduleLongRunning(Runnable runnable)

executeShortRunning

protected boolean executeShortRunning(Runnable runnable)

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

Parameters:

jobIds -

processEngine -

Returns:

getReference

public Reference getReference()

Specified by:

getReference in interface Referenceable

setReference

public void setReference(Reference reference)

Specified by:

setReference in interface jakarta.resource.Referenceable

getWorkManager

public jakarta.resource.spi.work.WorkManager getWorkManager()

getPlatformJobExecutorConnector

public JcaExecutorServiceConnector getPlatformJobExecutorConnector()