Package | Description |
---|---|
com.amazonaws.services.sqs | |
com.amazonaws.services.sqs.buffered | |
com.amazonaws.services.sqs.model | |
com.amazonaws.services.sqs.model.transform |
Modifier and Type | Method and Description |
---|---|
ReceiveMessageResult |
AmazonSQSClient.receiveMessage(ReceiveMessageRequest receiveMessageRequest)
Retrieves one or more messages, with a maximum limit of 10 messages, from
the specified queue.
|
ReceiveMessageResult |
AmazonSQS.receiveMessage(ReceiveMessageRequest receiveMessageRequest)
Retrieves one or more messages, with a maximum limit of 10 messages, from
the specified queue.
|
ReceiveMessageResult |
AbstractAmazonSQS.receiveMessage(ReceiveMessageRequest request) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsyncClient.receiveMessageAsync(ReceiveMessageRequest request) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsync.receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest)
Retrieves one or more messages, with a maximum limit of 10 messages, from
the specified queue.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AbstractAmazonSQSAsync.receiveMessageAsync(ReceiveMessageRequest request) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsyncClient.receiveMessageAsync(ReceiveMessageRequest request,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsync.receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler)
Retrieves one or more messages, with a maximum limit of 10 messages, from
the specified queue.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AbstractAmazonSQSAsync.receiveMessageAsync(ReceiveMessageRequest request,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsyncClient.receiveMessageAsync(ReceiveMessageRequest request,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsync.receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler)
Retrieves one or more messages, with a maximum limit of 10 messages, from
the specified queue.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AbstractAmazonSQSAsync.receiveMessageAsync(ReceiveMessageRequest request,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsyncClient.receiveMessageAsync(java.lang.String queueUrl,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler)
Simplified method form for invoking the ReceiveMessage operation with an
AsyncHandler.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSAsync.receiveMessageAsync(java.lang.String queueUrl,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler)
Simplified method form for invoking the ReceiveMessage operation with an
AsyncHandler.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AbstractAmazonSQSAsync.receiveMessageAsync(java.lang.String queueUrl,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler)
Simplified method form for invoking the ReceiveMessage operation with an
AsyncHandler.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
private boolean |
QueueBuffer.canBeRetrievedFromQueueBuffer(ReceiveMessageRequest rq)
We prefetch and load results in the buffer by making basic requests.
|
private boolean |
QueueBuffer.hasRequestedMessageAttributes(ReceiveMessageRequest rq) |
private boolean |
QueueBuffer.hasRequestedQueueAttributes(ReceiveMessageRequest rq) |
ReceiveMessageResult |
AmazonSQSBufferedAsyncClient.receiveMessage(ReceiveMessageRequest receiveMessageRequest) |
java.util.concurrent.Future<ReceiveMessageResult> |
QueueBuffer.receiveMessage(ReceiveMessageRequest rq,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> handler)
Submits a request to receive some messages from SQS.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSBufferedAsyncClient.receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest) |
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSBufferedAsyncClient.receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
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.
|
ReceiveMessageResult |
QueueBuffer.receiveMessageSync(ReceiveMessageRequest rq)
Retrieves messages from an SQS queue.
|
Modifier and Type | Method and Description |
---|---|
private ReceiveQueueBuffer.ReceiveMessageFuture |
ReceiveQueueBuffer.issueFuture(int size,
QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> callback)
Creates and returns a new future object.
|
java.util.concurrent.Future<ReceiveMessageResult> |
QueueBuffer.receiveMessage(ReceiveMessageRequest rq,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> handler)
Submits a request to receive some messages from SQS.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSBufferedAsyncClient.receiveMessageAsync(ReceiveMessageRequest receiveMessageRequest,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
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.
|
java.util.concurrent.Future<ReceiveMessageResult> |
AmazonSQSBufferedAsyncClient.receiveMessageAsync(java.lang.String queueUrl,
AsyncHandler<ReceiveMessageRequest,ReceiveMessageResult> asyncHandler) |
Constructor and Description |
---|
ReceiveMessageFuture(QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> cb,
int paramSize) |
Modifier and Type | Method and Description |
---|---|
ReceiveMessageRequest |
ReceiveMessageRequest.clone() |
ReceiveMessageRequest |
ReceiveMessageRequest.withAttributeNames(java.util.Collection<java.lang.String> attributeNames)
A list of attributes that need to be returned along with each message.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withAttributeNames(QueueAttributeName... attributeNames)
A list of attributes that need to be returned along with each message.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withAttributeNames(java.lang.String... attributeNames)
A list of attributes that need to be returned along with each message.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withMaxNumberOfMessages(java.lang.Integer maxNumberOfMessages)
The maximum number of messages to return.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withMessageAttributeNames(java.util.Collection<java.lang.String> messageAttributeNames)
The name of the message attribute, where N is the index.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withMessageAttributeNames(java.lang.String... messageAttributeNames)
The name of the message attribute, where N is the index.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withQueueUrl(java.lang.String queueUrl)
The URL of the Amazon SQS queue to take action on.
|
ReceiveMessageRequest |
ReceiveMessageRequest.withVisibilityTimeout(java.lang.Integer visibilityTimeout)
The duration (in seconds) that the received messages are hidden from
subsequent retrieve requests after being retrieved by a
ReceiveMessage request. |
ReceiveMessageRequest |
ReceiveMessageRequest.withWaitTimeSeconds(java.lang.Integer waitTimeSeconds)
The duration (in seconds) for which the call will wait for a message to
arrive in the queue before returning.
|
Modifier and Type | Method and Description |
---|---|
Request<ReceiveMessageRequest> |
ReceiveMessageRequestMarshaller.marshall(ReceiveMessageRequest receiveMessageRequest) |
Modifier and Type | Method and Description |
---|---|
Request<ReceiveMessageRequest> |
ReceiveMessageRequestMarshaller.marshall(ReceiveMessageRequest receiveMessageRequest) |