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

Class BaseBatchProcessingListenerOwner

java.lang.Object

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

All Implemented Interfaces:

BatchProcessingListenersOwner

Direct Known Subclasses:

DefaultBatchEngine, DefaultBatchJobInstanceStore, DefaultBatchQueueManager

public class BaseBatchProcessingListenerOwner
extends Object
implements BatchProcessingListenersOwner

Base class implementation for BatchProcessingListenersOwner which already implements some basic functionality like keeping the list of listeners, add/remove methods, etc.

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
BaseBatchProcessingListenerOwner()

Method Summary

Modifier and Type	Method and Description
void	addBatchProcessingListener(BatchJob job, BatchProcessingListener listener) Registers the given BatchProcessingListener for notifications triggered by DefaultBatchJobInstances of a given BatchJob.
void	addBatchProcessingListener(BatchProcessingListener listener) Registers the given BatchProcessingListener for notifications triggered by any DefaultBatchJobInstances regardless of the owning BatchJob.
protected List<BatchProcessingListener>	getListeners(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance)
boolean	removeBatchProcessingListener(BatchJob job, BatchProcessingListener listener) Removes the given BatchProcessingListener if registered to the given BatchJob
boolean	removeBatchProcessingListener(BatchProcessingListener listener) Removes the given BatchProcessingListener if registered as global

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseBatchProcessingListenerOwner

public BaseBatchProcessingListenerOwner()

Method Detail

addBatchProcessingListener

public void addBatchProcessingListener(BatchProcessingListener listener)

Registers the given BatchProcessingListener for notifications triggered by any DefaultBatchJobInstances regardless of the owning BatchJob. We call these listeners "global"

Listeners will be invoked in the following order:

The global listeners in the order they were added

The job specific listeners in the order they were added

Specified by:

addBatchProcessingListener in interface BatchProcessingListenersOwner

Parameters:

listener - a not null BatchProcessingListener

addBatchProcessingListener

public void addBatchProcessingListener(BatchJob job,
                                       BatchProcessingListener listener)

Registers the given BatchProcessingListener for notifications triggered by DefaultBatchJobInstances of a given BatchJob. Listeners will be invoked in the following order:

The global listeners in the order they were added

The job specific listeners in the order they were added