com.atlassian.bitbucket.concurrent

Interface BucketProcessor<T extends Serializable>

Type Parameters:

T - the task type

public interface BucketProcessor<T extends Serializable>

BucketedExecutor processor that's called when a bucket of tasks is ready for processing. Implementations need to ensure that the processing of a bucket of tasks completes or fails as a whole; when process(String, List) fails and the BucketedExecutor has been configured to retry processing, the whole bucket will be retried at a later time.

Method Summary

Modifier and Type	Method and Description
void	process(String bucketId, List<T> tasks) Callback method for processing a 'bucket' of tasks.

Method Detail

process

void process(@Nonnull
             String bucketId,
             @Nonnull
             List<T> tasks)

Callback method for processing a 'bucket' of tasks. Implementations need to ensure that processing of a bucket of tasks succeeds or fails as a whole. If the process method throws an exception and the executor has been configured to retry processing, all items in tasks will be re-offered at a later time.

Parameters:

bucketId - the bucket ID as determined by the configured ID extractor function.

tasks - the tasks that are ready for processing (at most batch size items.