| Modifier and Type | Method and Description |
|---|---|
void |
BatchProcessingListenersOwner.addBatchProcessingListener(BatchJob job,
BatchProcessingListener listener)
Registers the given
BatchProcessingListener for notifications triggered by
DefaultBatchJobInstances of a given BatchJob. |
void |
BatchProcessingListenersOwner.addBatchProcessingListener(BatchProcessingListener listener)
Registers the given
BatchProcessingListener for notifications triggered by any
DefaultBatchJobInstances regardless of the owning BatchJob. |
boolean |
BatchProcessingListenersOwner.removeBatchProcessingListener(BatchJob job,
BatchProcessingListener listener)
Removes the given
BatchProcessingListener if registered to the given
BatchJob |
boolean |
BatchProcessingListenersOwner.removeBatchProcessingListener(BatchProcessingListener listener)
Removes the given
BatchProcessingListener if registered as global |
| Modifier and Type | Method and Description |
|---|---|
BatchProcessingListener |
BatchRecordDispatcher.getListener()
A
BatchProcessingListener that you can use to notify this component on a
processing event |
| Modifier and Type | Class and Description |
|---|---|
class |
BaseBatchProcessingListener
Default implementation of
BatchProcessingListener which implements all the
methods with no-op implementations. |
| Modifier and Type | Method and Description |
|---|---|
protected List<BatchProcessingListener> |
BaseBatchProcessingListenerOwner.getListeners(com.mulesoft.mule.runtime.module.batch.api.BatchJobInstance jobInstance) |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseBatchProcessingListenerOwner.addBatchProcessingListener(BatchJob job,
BatchProcessingListener listener)
Registers the given
BatchProcessingListener for notifications triggered by
DefaultBatchJobInstances of a given BatchJob. |
void |
BaseBatchProcessingListenerOwner.addBatchProcessingListener(BatchProcessingListener listener)
Registers the given
BatchProcessingListener for notifications triggered by any
DefaultBatchJobInstances regardless of the owning BatchJob. |
boolean |
BaseBatchProcessingListenerOwner.removeBatchProcessingListener(BatchJob job,
BatchProcessingListener listener)
Removes the given
BatchProcessingListener if registered to the given
BatchJob |
boolean |
BaseBatchProcessingListenerOwner.removeBatchProcessingListener(BatchProcessingListener listener)
Removes the given
BatchProcessingListener if registered as global |
| Modifier and Type | Method and Description |
|---|---|
BatchProcessingListener |
BatchRecordDispatcherDelegate.getListener() |
BatchProcessingListener |
DefaultBatchRecordDispatcher.getListener() |
| Constructor and Description |
|---|
SteppingQueueDelegate(BatchJobInstanceAdapter jobInstance,
org.mule.runtime.core.api.util.queue.QueueManager queueManager,
long queueTimeout,
org.mule.runtime.api.serialization.ObjectSerializer serializer,
org.mule.runtime.core.api.MuleContext muleContext,
List<BatchProcessingListener> listeners) |
| Constructor and Description |
|---|
BatchRecordWork(BatchEngine batchEngine,
BatchJobAdapter job,
BatchTransactionContext ctx,
BatchProcessingListener listener,
List<Record> block) |
| Modifier and Type | Method and Description |
|---|---|
static void |
BatchUtils.completeWorkOnBlock(List<Record> block,
boolean shouldRollback,
BatchProcessingListener listener,
BatchTransactionContext ctx)
Perform the completion callback for each record in the block as well as any further completion operation needed related to
the transaction context.
|
Copyright © 2006–2022 MuleSoft, Inc.. All rights reserved.