Package | Description |
---|---|
com.amazonaws.services.sqs.buffered |
Modifier and Type | Class and Description |
---|---|
private class |
SendQueueBuffer.ChangeMessageVisibilityBatchTask |
private class |
SendQueueBuffer.DeleteMessageBatchTask |
private class |
SendQueueBuffer.SendMessageBatchTask |
Modifier and Type | Field and Description |
---|---|
private SendQueueBuffer.Listener<SendQueueBuffer.OutboundBatchTask<R,Result>> |
SendQueueBuffer.OutboundBatchTask.onCompleted |
Modifier and Type | Method and Description |
---|---|
(package private) <OBT extends SendQueueBuffer.OutboundBatchTask<R,Result>,R extends AmazonWebServiceRequest,Result> |
SendQueueBuffer.submitOutboundRequest(java.lang.Object operationLock,
OBT[] openOutboundBatchTask,
R request,
java.util.concurrent.Semaphore inflightOperationBatches,
QueueBufferCallback<R,Result> callback)
Submits an outbound request for delivery to the queue associated with this buffer.
|
Modifier and Type | Method and Description |
---|---|
private <R extends AmazonWebServiceRequest,Result> |
SendQueueBuffer.newOutboundBatchTask(R request) |
Modifier and Type | Method and Description |
---|---|
(package private) <OBT extends SendQueueBuffer.OutboundBatchTask<R,Result>,R extends AmazonWebServiceRequest,Result> |
SendQueueBuffer.submitOutboundRequest(java.lang.Object operationLock,
OBT[] openOutboundBatchTask,
R request,
java.util.concurrent.Semaphore inflightOperationBatches,
QueueBufferCallback<R,Result> callback)
Submits an outbound request for delivery to the queue associated with this buffer.
|
Modifier and Type | Method and Description |
---|---|
void |
SendQueueBuffer.OutboundBatchTask.setOnCompleted(SendQueueBuffer.Listener<SendQueueBuffer.OutboundBatchTask<R,Result>> value) |