| Modifier and Type | Method and Description |
|---|---|
BatchQueueDelegate |
BatchQueueManager.steppingQueue(BatchJobInstanceAdapter jobInstance)
|
BatchQueueDelegate |
BatchQueueManager.streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator |
BatchQueueDelegate |
BatchQueueManager.streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator |
| Modifier and Type | Method and Description |
|---|---|
protected BatchQueueDelegate |
StreamingAggregatorOutputQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance) |
protected abstract BatchQueueDelegate |
TransactionalQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance)
Returns the
BatchQueueDelegate through which information will be written into the queue |
protected BatchQueueDelegate |
SteppingQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance)
Returns a
BatchQueueDelegate for stepping queues returned by
BatchQueueManager.steppingQueue(BatchJobInstanceAdapter) |
protected BatchQueueDelegate |
StreamingAggregatorInputQueueBuffer.getDelegate(BatchJobInstanceAdapter jobInstance)
Returns a
BatchQueueDelegate for streaming aggregator queues |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBatchQueueDelegate
Base class for implementation of
BatchQueueDelegate |
class |
AbstractStreamingAggregatorQueueDelegate
Base class for implementations of
AbstractBatchQueueDelegate which depends on a
BatchStepAdapter |
class |
SteppingQueueDelegate
Implementation of
AbstractBatchQueueDelegate which accepts a list of
BatchProcessingListener to be invoked when
SteppingQueueDelegate.dispatch(com.mulesoft.mule.runtime.module.batch.engine.transaction.BatchTransactionContext, java.util.Collection)
finishes successfully |
class |
StreamingAggregatorInputQueueDelegate
Implementation of
AbstractStreamingAggregatorQueueDelegate for a streaming aggregator input queue |
class |
StreamingAggregatorOutputQueueDelegate |
| Modifier and Type | Method and Description |
|---|---|
BatchQueueDelegate |
DefaultBatchQueueManager.steppingQueue(BatchJobInstanceAdapter jobInstance)
|
BatchQueueDelegate |
DefaultBatchQueueManager.streamingAggregatorInputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the input queue of a streaming BatchStepAggregator |
BatchQueueDelegate |
DefaultBatchQueueManager.streamingAggregatorOutputQueue(BatchJobInstanceAdapter jobInstance,
BatchStepAdapter step)
Returns a
BatchQueueDelegate to access the output queue of a streaming BatchStepAggregator |
Copyright © 2006–2022 MuleSoft, Inc.. All rights reserved.