org.jclouds.sqs.features

Interface MessageAsyncApi

public interface MessageAsyncApi

Provides access to SQS via their REST API.

Author:

Adrian Cole

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>>	changeVisibility(Iterable<String> receiptHandles, int visibilityTimeout)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>>	changeVisibility(Map<String,Integer> receiptHandleVisibilityTimeout)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>>	changeVisibility(Map<String,String> idReceiptHandle, int visibilityTimeout)
com.google.common.util.concurrent.ListenableFuture<Void>	changeVisibility(String receiptHandle, int visibilityTimeout)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>>	changeVisibility(com.google.common.collect.Table<String,String,Integer> idReceiptHandleVisibilityTimeout)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>>	delete(Iterable<String> receiptHandles)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>>	delete(Map<String,String> idReceiptHandle)
com.google.common.util.concurrent.ListenableFuture<Void>	delete(String receiptHandle)
com.google.common.util.concurrent.ListenableFuture<Message>	receive()
com.google.common.util.concurrent.ListenableFuture<? extends com.google.common.collect.FluentIterable<? extends Message>>	receive(int max)
com.google.common.util.concurrent.ListenableFuture<? extends com.google.common.collect.FluentIterable<? extends Message>>	receive(int max, ReceiveMessageOptions options)
com.google.common.util.concurrent.ListenableFuture<? extends Message>	receive(ReceiveMessageOptions options)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>>	send(Iterable<String> messageBodies)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>>	send(Map<String,String> idMessageBody)
com.google.common.util.concurrent.ListenableFuture<? extends MessageIdAndMD5>	send(String message)
com.google.common.util.concurrent.ListenableFuture<? extends MessageIdAndMD5>	send(String message, SendMessageOptions options)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>>	sendWithDelay(Iterable<String> messageBodies, int delaySeconds)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>>	sendWithDelay(Map<String,String> idMessageBody, int delaySeconds)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>>	sendWithDelays(Map<String,Integer> messageBodyDelaySeconds)
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>>	sendWithDelays(com.google.common.collect.Table<String,String,Integer> idMessageBodyDelaySeconds)

Method Detail

delete

@Named(value="sqs:DeleteMessage")
com.google.common.util.concurrent.ListenableFuture<Void> delete(String receiptHandle)

See Also:

MessageApi.delete(String)

delete

@Named(value="sqs:DeleteMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>> delete(Map<String,String> idReceiptHandle)

See Also:

MessageApi.delete(Map)

delete

@Named(value="sqs:DeleteMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>> delete(Iterable<String> receiptHandles)

See Also:

MessageApi.delete(Iterable)

changeVisibility

@Named(value="sqs:ChangeMessageVisibility")
com.google.common.util.concurrent.ListenableFuture<Void> changeVisibility(String receiptHandle,
                                                                              int visibilityTimeout)

See Also:

MessageApi.changeVisibility(String, int)

changeVisibility

@Named(value="sqs:ChangeMessageVisibilityBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>> changeVisibility(com.google.common.collect.Table<String,String,Integer> idReceiptHandleVisibilityTimeout)

See Also:

MessageApi.changeVisibility(Table)

changeVisibility

@Named(value="sqs:ChangeMessageVisibilityBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>> changeVisibility(Map<String,Integer> receiptHandleVisibilityTimeout)

See Also:

MessageApi.changeVisibility(Map)

changeVisibility

@Named(value="sqs:ChangeMessageVisibilityBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>> changeVisibility(Map<String,String> idReceiptHandle,
                                                                                                       int visibilityTimeout)

See Also:

MessageApi.changeVisibility(Map, int)

changeVisibility

@Named(value="sqs:ChangeMessageVisibilityBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<String>> changeVisibility(Iterable<String> receiptHandles,
                                                                                                       int visibilityTimeout)

See Also:

MessageApi.changeVisibility(Iterable, int)

send

@Named(value="sqs:SendMessage")
com.google.common.util.concurrent.ListenableFuture<? extends MessageIdAndMD5> send(String message)

See Also:

MessageApi.send(String)

send

@Named(value="sqs:SendMessage")
com.google.common.util.concurrent.ListenableFuture<? extends MessageIdAndMD5> send(String message,
                                                                                       SendMessageOptions options)

See Also:

MessageApi.send(String, SendMessageOptions)

sendWithDelays

@Named(value="sqs:SendMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>> sendWithDelays(com.google.common.collect.Table<String,String,Integer> idMessageBodyDelaySeconds)

See Also:

MessageApi.sendWithDelays(Table)

sendWithDelays

@Named(value="sqs:SendMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>> sendWithDelays(Map<String,Integer> messageBodyDelaySeconds)

See Also:

MessageApi.sendWithDelays(Map)

sendWithDelay

@Named(value="sqs:SendMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>> sendWithDelay(Map<String,String> idMessageBody,
                                                                                                                       int delaySeconds)

See Also:

MessageApi.sendWithDelay(Map, int)

sendWithDelay

@Named(value="sqs:SendMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>> sendWithDelay(Iterable<String> messageBodies,
                                                                                                                       int delaySeconds)

See Also:

MessageApi.sendWithDelay(Iterable, int)

send

@Named(value="sqs:SendMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>> send(Map<String,String> idMessageBody)

See Also:

MessageApi.send(Map)

send

@Named(value="sqs:SendMessageBatch")
com.google.common.util.concurrent.ListenableFuture<? extends BatchResult<? extends MessageIdAndMD5>> send(Iterable<String> messageBodies)

See Also:

MessageApi.send(Iterable)

receive

@Named(value="sqs:ReceiveMessage")
com.google.common.util.concurrent.ListenableFuture<Message> receive()

See Also:

MessageApi.receive()

receive

@Named(value="sqs:ReceiveMessage")
com.google.common.util.concurrent.ListenableFuture<? extends Message> receive(ReceiveMessageOptions options)

See Also:

MessageApi.receive(ReceiveMessageOptions)

receive

@Named(value="sqs:ReceiveMessage")
com.google.common.util.concurrent.ListenableFuture<? extends com.google.common.collect.FluentIterable<? extends Message>> receive(int max)

See Also:

MessageApi.receive(int)

receive

@Named(value="sqs:ReceiveMessage")
com.google.common.util.concurrent.ListenableFuture<? extends com.google.common.collect.FluentIterable<? extends Message>> receive(int max,
                                                                                                                                      ReceiveMessageOptions options)

See Also:

MessageApi.receive(int, ReceiveMessageOptions)