Package | Description |
---|---|
com.amazonaws.services.sqs.buffered |
Modifier and Type | Class and Description |
---|---|
private class |
ReceiveQueueBuffer.ReceiveMessageFuture |
Modifier and Type | Field and Description |
---|---|
protected java.util.ArrayList<QueueBufferFuture<R,Result>> |
SendQueueBuffer.OutboundBatchTask.futures |
Modifier and Type | Method and Description |
---|---|
private QueueBufferFuture<R,Result> |
SendQueueBuffer.OutboundBatchTask.addIfAllowed(R request,
QueueBufferCallback<R,Result> callback)
Adds the request to the batch if capacity allows it.
|
QueueBufferFuture<R,Result> |
SendQueueBuffer.OutboundBatchTask.addRequest(R request,
QueueBufferCallback<R,Result> callback)
Adds a request to the batch if it is still open and has capacity.
|
QueueBufferFuture<ChangeMessageVisibilityRequest,ChangeMessageVisibilityResult> |
SendQueueBuffer.changeMessageVisibility(ChangeMessageVisibilityRequest request,
QueueBufferCallback<ChangeMessageVisibilityRequest,ChangeMessageVisibilityResult> callback) |
QueueBufferFuture<DeleteMessageRequest,DeleteMessageResult> |
SendQueueBuffer.deleteMessage(DeleteMessageRequest request,
QueueBufferCallback<DeleteMessageRequest,DeleteMessageResult> callback) |
QueueBufferFuture<ReceiveMessageRequest,ReceiveMessageResult> |
ReceiveQueueBuffer.receiveMessageAsync(ReceiveMessageRequest rq,
QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> callback)
Submits the request for retrieval of messages from the queue and returns a future that will
be signalled when the request is satisfied.
|
QueueBufferFuture<SendMessageRequest,SendMessageResult> |
SendQueueBuffer.sendMessage(SendMessageRequest request,
QueueBufferCallback<SendMessageRequest,SendMessageResult> callback) |
(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 |
---|---|
protected void |
SendQueueBuffer.ChangeMessageVisibilityBatchTask.process(java.util.List<ChangeMessageVisibilityRequest> requests,
java.util.List<QueueBufferFuture<ChangeMessageVisibilityRequest,ChangeMessageVisibilityResult>> futures) |
protected void |
SendQueueBuffer.DeleteMessageBatchTask.process(java.util.List<DeleteMessageRequest> requests,
java.util.List<QueueBufferFuture<DeleteMessageRequest,DeleteMessageResult>> futures) |
protected abstract void |
SendQueueBuffer.OutboundBatchTask.process(java.util.List<R> requests,
java.util.List<QueueBufferFuture<R,Result>> futures)
Processes the batch once closed.
|
protected void |
SendQueueBuffer.SendMessageBatchTask.process(java.util.List<SendMessageRequest> requests,
java.util.List<QueueBufferFuture<SendMessageRequest,SendMessageResult>> futures) |