Interface ThresholdBatchReceiver<BatchT> (2.49.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
Name Description
BatchT

Methods

processBatch(BatchT batch)

public abstract ApiFuture<?> processBatch(BatchT batch)

Process the given batch asynchronously.

Parameter
Name Description
batch BatchT
Returns
Type Description
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
Name Description
message BatchT