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

Class BatchContextTransactionRecorder

java.lang.Object

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

public class BatchContextTransactionRecorder
extends Object

Recorder for batch transaction contexts to prevent commit when an aggregator is flushed.

Since:

4.4.0, 4.3.1, 4.2.3

Constructor Summary

Constructors

Constructor and Description
BatchContextTransactionRecorder(BatchEngine batchEngine)

Method Summary

Modifier and Type	Method and Description
void	flushAndForget(BatchJobInstanceAdapter jobInstance) Flushes all the records corresponding to the batch context for the job instance.
Integer	size(BatchJobInstanceAdapter jobInstance) Returns the size of the not flushed records.
void	tryFlush(BatchTransactionContext ctx, List<Record> records) Attempts to flush records and update statistics.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchContextTransactionRecorder

public BatchContextTransactionRecorder(BatchEngine batchEngine)

Method Detail

tryFlush

public void tryFlush(BatchTransactionContext ctx,
                     List<Record> records)
              throws org.mule.runtime.api.exception.MuleException

Attempts to flush records and update statistics. In case the block size is not achieved it keeps the records for future flush.

Parameters:

ctx - batch transaction context

records - records aggregated.

Throws:

org.mule.runtime.api.exception.MuleException - an exception in the flush process.

size

public Integer size(BatchJobInstanceAdapter jobInstance)

Returns the size of the not flushed records.

Parameters:

jobInstance - job instance

Returns:

number of retained records.

flushAndForget

public void flushAndForget(BatchJobInstanceAdapter jobInstance)
                    throws org.mule.runtime.api.exception.MuleException

Flushes all the records corresponding to the batch context for the job instance.

Parameters:

jobInstance - job instance

Throws:

org.mule.runtime.api.exception.MuleException - an exception during the flusing process.