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

Class DefaultBatchRecordDispatcher

java.lang.Object

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

All Implemented Interfaces:

BatchRecordDispatcher

public class DefaultBatchRecordDispatcher
extends Object
implements BatchRecordDispatcher

Default implementation of BatchRecordDispatcher which does the monitoring in a single thread and processes using a BatchWorkManager

Since:

3.5.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	BATCH_DISPATCHER_THREAD_NAME

Constructor Summary

Constructors

Constructor and Description
DefaultBatchRecordDispatcher(BatchEngine batchEngine, BatchWorkManager workManager, org.mule.runtime.api.scheduler.SchedulerService schedulerService, org.mule.runtime.api.scheduler.SchedulerConfig schedulerBaseConfig, org.mule.runtime.api.notification.NotificationListenerRegistry notificationListenerRegistry)

Method Summary

Modifier and Type	Method and Description
BatchProcessingListener	getListener() A BatchProcessingListener that you can use to notify this component on a processing event
void	start() Starts the queue monitoring.
void	stop() Stops monitoring.

Methods inherited from class java.lang.Object

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

Field Detail

BATCH_DISPATCHER_THREAD_NAME

public static final String BATCH_DISPATCHER_THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

DefaultBatchRecordDispatcher

public DefaultBatchRecordDispatcher(BatchEngine batchEngine,
                                    BatchWorkManager workManager,
                                    org.mule.runtime.api.scheduler.SchedulerService schedulerService,
                                    org.mule.runtime.api.scheduler.SchedulerConfig schedulerBaseConfig,
                                    org.mule.runtime.api.notification.NotificationListenerRegistry notificationListenerRegistry)

Method Detail

start

public void start()

Description copied from interface: BatchRecordDispatcher

Starts the queue monitoring. Implementations are not required to start monitoring immediatly after invocation of this method.

Specified by:

start in interface BatchRecordDispatcher

stop

public void stop()

Description copied from interface: BatchRecordDispatcher

Stops monitoring. Implementations are not required to have fully stopped the monitoring upon invocation of this method.

Specified by:

stop in interface BatchRecordDispatcher

getListener

public BatchProcessingListener getListener()

Description copied from interface: BatchRecordDispatcher

A BatchProcessingListener that you can use to notify this component on a processing event

Specified by:

getListener in interface BatchRecordDispatcher

Returns:

a BatchProcessingListener