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

Class StreamingAggregatorOutputQueueBuffer

java.lang.Object

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

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

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

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

All Implemented Interfaces:

BatchContextTransactionManager, RecordBuffer, org.mule.runtime.api.meta.NamedObject

public class StreamingAggregatorOutputQueueBuffer
extends AbstractStreamingAggregatorQueueBuffer

Implementation of AbstractStreamingAggregatorQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.streamingAggregatorOutputQueue(com.mulesoft.mule.runtime.module.batch.engine.BatchJobInstanceAdapter, com.mulesoft.mule.runtime.module.batch.engine.BatchStepAdapter)

Since:

3.5.0

Field Summary

Fields inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractStreamingAggregatorQueueBuffer

step

Fields inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

batchQueueManager

Constructor Summary

Constructors

Constructor and Description
StreamingAggregatorOutputQueueBuffer(BatchEngine batchEngine, BatchStepAdapter step)

Method Summary

Modifier and Type	Method and Description
protected BatchQueueDelegate	getDelegate(BatchJobInstanceAdapter jobInstance) Returns the BatchQueueDelegate through which information will be written into the queue

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.TransactionalQueueBuffer

add, commit, doFlush, doForget, flush, flushAndForget, forget, rollback, size

Methods inherited from class com.mulesoft.mule.runtime.module.batch.internal.engine.buffer.AbstractRecordBuffer

add, getName

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingAggregatorOutputQueueBuffer

public StreamingAggregatorOutputQueueBuffer(BatchEngine batchEngine,
                                            BatchStepAdapter step)

Method Detail

getDelegate

protected BatchQueueDelegate getDelegate(BatchJobInstanceAdapter jobInstance)

Description copied from class: TransactionalQueueBuffer

Returns the BatchQueueDelegate through which information will be written into the queue

Specified by:

getDelegate in class TransactionalQueueBuffer

Returns:

a BatchQueueDelegate