Interface ThresholdBatchReceiver<BatchT> (2.21.0)

public interface ThresholdBatchReceiver<BatchT>

Interface representing an object that receives batches from a ThresholdBatcher and takes action on them. Implementations of ThresholdBatchReceiver should be thread-safe.

Type Parameter

NameDescription
BatchT

Methods

processBatch(BatchT batch)

public abstract ApiFuture<?> processBatch(BatchT batch)

Process the given batch asynchronously.

Parameter
NameDescription
batchBatchT
Returns
TypeDescription
ApiFuture<?>

validateBatch(BatchT message)

public abstract void validateBatch(BatchT message)

Validate that the batch can be received by this ThresholdBatchReceiver. This is called to validate a batch before it is sent to the ThresholdBatcher.

Parameter
NameDescription
messageBatchT