Package | Description |
---|---|
com.amazonaws.services.sqs.buffered |
Modifier and Type | Field and Description |
---|---|
private QueueBufferCallback<Req,Res> |
QueueBufferFuture.callback
callback we should call after the future is done.
|
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) |
private ReceiveQueueBuffer.ReceiveMessageFuture |
ReceiveQueueBuffer.issueFuture(int size,
QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> callback)
Creates and returns a new future object.
|
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.
|
Constructor and Description |
---|
QueueBufferFuture(QueueBufferCallback<Req,Res> cb) |
ReceiveMessageFuture(QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> cb,
int paramSize) |