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
com.google.api.core.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.