AmazonSQSRequester.java

package com.amazonaws.services.sqs;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

import com.amazonaws.services.sqs.AmazonSQS;
import com.amazonaws.services.sqs.model.Message;
import com.amazonaws.services.sqs.model.SendMessageRequest;

public interface AmazonSQSRequester {

    AmazonSQS getAmazonSQS();

    /**
     * Sends a message and waits the given amount of time for
     * the response message.
     */
    public Message sendMessageAndGetResponse(SendMessageRequest request, 
            int timeout, TimeUnit unit) throws TimeoutException;

    /**
     * Sends a message and returns a <tt>CompletableFuture</tt> 
     * that will be completed with the response message when it arrives.
     */
    public CompletableFuture<Message> sendMessageAndGetResponseAsync(SendMessageRequest request, 
            int timeout, TimeUnit unit);

    public void shutdown();
}