com.mulesoft.mule.runtime.module.batch.internal.engine.threading

Class DefaultBatchWorkManager

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.engine.threading.DefaultBatchWorkManager

All Implemented Interfaces:

BatchWorkManager, org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable, org.mule.runtime.core.api.context.MuleContextAware

public class DefaultBatchWorkManager
extends Object
implements BatchWorkManager, org.mule.runtime.core.api.context.MuleContextAware

Default implementation of BatchWorkManager

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Stoppable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
DefaultBatchWorkManager()

Method Summary

Modifier and Type	Method and Description
void	awaitStop(BatchJobInstanceAdapter jobInstance) Makes the given jobInstance no longer executable (further invocations to BatchWorkManager.scheduleRecordWork(BatchTransactionContext, Runnable) will fail, and also waits for the currently scheduled tasks to complete before returning
void	executable(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance) Tracks the given jobInstance as an executable one.
void	scheduleManagementWork(Runnable work) Schedules the asynchronous execution of a job management task.
void	scheduleRecordWork(BatchTransactionContext ctx, Runnable work) Schedules the given work to be executed.
void	setBatchEngine(BatchEngine batchEngine)
void	setMuleContext(org.mule.runtime.core.api.MuleContext muleContext)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBatchWorkManager

public DefaultBatchWorkManager()

Method Detail

start

public void start()
           throws org.mule.runtime.api.exception.MuleException

Specified by:

start in interface org.mule.runtime.api.lifecycle.Startable

Throws:

org.mule.runtime.api.exception.MuleException

stop

public void stop()

Specified by:

stop in interface org.mule.runtime.api.lifecycle.Stoppable

executable

public void executable(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance)

Tracks the given jobInstance as an executable one. Invoking BatchWorkManager.scheduleRecordWork(BatchTransactionContext, Runnable) before registering the corresponding job instance with this method, will result in an IllegalStateException.

Furthermore, it's the invoker's responsibility to eventually call the BatchWorkManager.awaitStop(BatchJobInstanceAdapter) to un-track the job instance and properly release resources

Specified by:

executable in interface BatchWorkManager

Parameters:

jobInstance - an executable jobInstance

scheduleManagementWork

public void scheduleManagementWork(Runnable work)

Schedules the asynchronous execution of a job management task. These tasks should not involve record processing

Specified by:

scheduleManagementWork in interface BatchWorkManager

Parameters:

work - the task to execute

scheduleRecordWork

public void scheduleRecordWork(BatchTransactionContext ctx,
                               Runnable work)
                        throws RejectedExecutionException

Schedules the given work to be executed. If this method is invoked while the MuleContext is stopped or stopping, then the work is silently discarded and the context is rolled back.

Specified by:

scheduleRecordWork in interface BatchWorkManager

Parameters:

ctx - the BatchTransactionContext referencing the transaction of which work is a part of

work - a javax.resource.spi.work.Work

Throws:

RejectedExecutionException - if the underlying Executor cannot execute the given work.

awaitStop

public void awaitStop(BatchJobInstanceAdapter jobInstance)

Makes the given jobInstance no longer executable (further invocations to BatchWorkManager.scheduleRecordWork(BatchTransactionContext, Runnable) will fail, and also waits for the currently scheduled tasks to complete before returning

Specified by:

awaitStop in interface BatchWorkManager

Parameters:

jobInstance - an executable jobInstance

setBatchEngine

@Inject
 @Named(value="batch.engine")
public void setBatchEngine(BatchEngine batchEngine)

setMuleContext

public void setMuleContext(org.mule.runtime.core.api.MuleContext muleContext)

Specified by:

setMuleContext in interface org.mule.runtime.core.api.context.MuleContextAware