com.mulesoft.mule.runtime.module.batch.api.record

Interface RecordCompletionTracker

All Known Implementing Classes:

RecordCompletableFuture

public interface RecordCompletionTracker

Allows to track the concurrent uses of a record.

Since:

4.1.5

Method Summary

Modifier and Type	Method and Description
void	decrementConsumers() Reverse of incrementConsumers()
void	incrementConsumers() Adds one to the count of components which are currently consuming a Record.

Method Detail

incrementConsumers

void incrementConsumers()

Adds one to the count of components which are currently consuming a Record. Because a record can be used in a step at the same time that it's sitting in the queue of one or many RecordBuffer (aggregators, stepping queues, etc), this method allows to track how many components depend on a particular instance, so that we know when can we safely release all the resources currently associated to the record.

decrementConsumers

void decrementConsumers()

Reverse of incrementConsumers()