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

Class BatchRecordDispatcherDelegate

java.lang.Object

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

All Implemented Interfaces:

Runnable

public class BatchRecordDispatcherDelegate
extends Object
implements Runnable

Delegate implementation of BatchRecordDispatcher which processes in a single thread backed by a Scheduler and dispatches processes using a BatchWorkManager

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
BatchRecordDispatcherDelegate(BatchEngine batchEngine, BatchWorkManager workManager)

Method Summary

Modifier and Type	Method and Description
BatchProcessingListener	getListener()
void	run()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchRecordDispatcherDelegate

public BatchRecordDispatcherDelegate(BatchEngine batchEngine,
                                     BatchWorkManager workManager)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

getListener

public BatchProcessingListener getListener()