org.camunda.bpm.container.impl.jboss.service

Class MscExecutorService

java.lang.Object

org.camunda.bpm.container.impl.jboss.service.MscExecutorService

All Implemented Interfaces:

ExecutorService, org.jboss.msc.service.Service<MscExecutorService>, org.jboss.msc.value.Value<MscExecutorService>

public class MscExecutorService
extends Object
implements org.jboss.msc.service.Service<MscExecutorService>, ExecutorService

Field Summary

Fields inherited from interface org.jboss.msc.service.Service

NULL, NULL_VALUE

Constructor Summary

Constructors

Constructor and Description
MscExecutorService()

Method Summary

Methods

Modifier and Type	Method and Description
Runnable	getExecuteJobsRunnable(List<String> jobIds, ProcessEngineImpl processEngine) Returns a runnable to be used for executing Jobs.
org.jboss.msc.value.InjectedValue<org.jboss.as.threads.ManagedQueueExecutorService>	getManagedQueueInjector()
MscExecutorService	getValue()
boolean	schedule(Runnable runnable, boolean isLongRunning) Passes a Runnable to the runtime container for execution.
protected boolean	scheduleLongRunningWork(Runnable runnable)
protected boolean	scheduleShortRunningWork(Runnable runnable)
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

MscExecutorService

public MscExecutorService()

Method Detail

getValue

public MscExecutorService getValue()
                            throws IllegalStateException,
                                   IllegalArgumentException

Specified by:

getValue in interface org.jboss.msc.value.Value<MscExecutorService>

Throws:

IllegalStateException

IllegalArgumentException

start

public void start(org.jboss.msc.service.StartContext context)
           throws org.jboss.msc.service.StartException

Specified by:

start in interface org.jboss.msc.service.Service<MscExecutorService>

Throws:

org.jboss.msc.service.StartException

stop

public void stop(org.jboss.msc.service.StopContext context)

Specified by:

stop in interface org.jboss.msc.service.Service<MscExecutorService>

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:

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.

scheduleShortRunningWork

protected boolean scheduleShortRunningWork(Runnable runnable)

scheduleLongRunningWork

protected boolean scheduleLongRunningWork(Runnable runnable)

getManagedQueueInjector

public org.jboss.msc.value.InjectedValue<org.jboss.as.threads.ManagedQueueExecutorService> getManagedQueueInjector()