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

Class SteppingQueueBuffer

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.SteppingQueueBuffer

All Implemented Interfaces:

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

public class SteppingQueueBuffer
extends TransactionalQueueBuffer

Implementation of TransactionalQueueBuffer which flushes data using the BatchQueueDelegate returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)

Since:

3.5.0

Field Summary

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

batchQueueManager

Constructor Summary

Constructors

Constructor and Description
SteppingQueueBuffer(BatchEngine batchEngine)

Method Summary

Modifier and Type	Method and Description
protected BatchQueueDelegate	getDelegate(BatchJobInstanceAdapter jobInstance) Returns a BatchQueueDelegate for stepping queues returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)

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

SteppingQueueBuffer

public SteppingQueueBuffer(BatchEngine batchEngine)

Method Detail

getDelegate

protected BatchQueueDelegate getDelegate(BatchJobInstanceAdapter jobInstance)

Returns a BatchQueueDelegate for stepping queues returned by BatchQueueManager.steppingQueue(BatchJobInstanceAdapter)

Specified by:

getDelegate in class TransactionalQueueBuffer

Returns:

a BatchQueueDelegate