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

Class AbstractStreamingAggregatorQueueBuffer

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

All Implemented Interfaces:

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

Direct Known Subclasses:

StreamingAggregatorInputQueueBuffer, StreamingAggregatorOutputQueueBuffer

public abstract class AbstractStreamingAggregatorQueueBuffer
extends TransactionalQueueBuffer

Base class for implementations of TransactionalQueueBuffer that rely on a BatchStep

Field Summary

Fields

Modifier and Type	Field and Description
protected BatchStepAdapter	step

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

batchQueueManager

Constructor Summary

Constructors

Constructor and Description
AbstractStreamingAggregatorQueueBuffer(String name, BatchEngine batchEngine, BatchStepAdapter step)

Method Summary

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

add, commit, doFlush, doForget, flush, flushAndForget, forget, getDelegate, 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

Field Detail

step

protected final BatchStepAdapter step

Constructor Detail

AbstractStreamingAggregatorQueueBuffer

public AbstractStreamingAggregatorQueueBuffer(String name,
                                              BatchEngine batchEngine,
                                              BatchStepAdapter step)