Support of AWS SQS for Java

Objects

IconDescription
Alt textJava AWS SQS Publisher
Alt textJava AWS SQS Receiver
Alt textJava AWS SQS Unknown Publisher
Alt textJava AWS SQS Unknown Receiver
Link TypeFunction
callLinksendMessage, sendMessageBatch, receiveMessage

Code samples

In this code, the sendMessage publishes a into the “testQueue” queue and the receiveMessage receive a message from the same SQS queue:

package aws.example.sqs;
import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.AmazonSQSClientBuilder;
import com.amazonaws.services.sqs.model.AmazonSQSException;
import com.amazonaws.services.sqs.model.CreateQueueResult;
import com.amazonaws.services.sqs.model.Message;
import com.amazonaws.services.sqs.model.SendMessageBatchRequest;
import com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry;
import com.amazonaws.services.sqs.model.SendMessageRequest;


public class SendReceiveMessages
{

    public static void sendMessage(String[] args)
    {
        final AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();

        String queueUrl = sqs.getQueueUrl("testQueue").getQueueUrl();

        SendMessageRequest send_msg_request = new SendMessageRequest()
                .withQueueUrl(queueUrl)
                .withMessageBody("hello world")
                .withDelaySeconds(5);
        sqs.sendMessage(send_msg_request);
    }

    public static void receiveMessage()
    {

        final AmazonSQS sqs = AmazonSQSClientBuilder.defaultClient();

        String queueUrl = sqs.getQueueUrl("testQueue").getQueueUrl(); 

        // receive messages from the queue
        List<Message> messages = sqs.receiveMessage(queueUrl).getMessages();


    }
}

Alt text

Known limitations

  • Use of AmazonSQSRequester and AmazonSQSResponder and AbstractAmazonSQSClientWrapper is not supported