private class SendQueueBuffer.DeleteMessageBatchTask extends SendQueueBuffer.OutboundBatchTask<DeleteMessageRequest,DeleteMessageResult>
futures, requests
Modifier | Constructor and Description |
---|---|
private |
DeleteMessageBatchTask() |
Modifier and Type | Method and Description |
---|---|
protected void |
process(java.util.List<DeleteMessageRequest> requests,
java.util.List<QueueBufferFuture<DeleteMessageRequest,DeleteMessageResult>> futures)
Processes the batch once closed.
|
addRequest, isFull, isOkToAdd, onRequestAdded, run, setOnCompleted
protected void process(java.util.List<DeleteMessageRequest> requests, java.util.List<QueueBufferFuture<DeleteMessageRequest,DeleteMessageResult>> futures)
SendQueueBuffer.OutboundBatchTask
this
.
However, it's passed a local copy of both the requests
and futures
lists
made while holding the lock.process
in class SendQueueBuffer.OutboundBatchTask<DeleteMessageRequest,DeleteMessageResult>