| com.atlassian.bitbucket.concurrent.BucketProcessor<T extends java.io.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.
| Public Methods | |||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
Callback method for processing a 'bucket' of 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.
| 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.
|