Usar a Biblioteca de Mensagens Java do Amazon SQS

Crie uma connection factory e chame o método createConnection contra a factory.

// Create a new connection factory with all defaults (credentials and region) set automatically
SQSConnectionFactory connectionFactory = new SQSConnectionFactory(
        new ProviderConfiguration(),
        AmazonSQSClientBuilder.defaultClient()
        );
 
// Create the connection.
SQSConnection connection = connectionFactory.createConnection();

A classe SQSConnection estende javax.jms.Connection. Com os métodos de conexão do JMS padrão, SQSConnection oferece métodos adicionais, como getAmazonSQSClient e getWrappedAmazonSQSClient. Os dois métodos permitem que você execute operações administrativas não incluídas na especificação JMS, como a criação de novas filas. Contudo, o método getWrappedAmazonSQSClient também fornece uma versão encapsulada do cliente do Amazon SQS usada pela conexão atual. O wrapper transforma cada exceção de um cliente em um JMSException, permitindo que ele seja mais facilmente usado pelo código existente que espera ocorrências de JMSException.

Você pode usar objetos de cliente retornados de getAmazonSQSClient e de getWrappedAmazonSQSClient para executar operações administrativas não incluídas na especificação do JMS (por exemplo, você pode criar uma fila do Amazon SQS).

Se você tiver um código que espera exceções JMS, deve usar getWrappedAmazonSQSClient:

Quando a conexão e a fila do Amazon SQS subjacente estiverem prontas, crie uma sessão JMS sem transação com o modo AUTO_ACKNOWLEDGE.

// Create the nontransacted session with AUTO_ACKNOWLEDGE mode
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

Para enviar uma mensagem de texto para a fila, crie uma identidade de fila JMS e um produtor de mensagem.

// Create a queue identity and specify the queue name to the session
Queue queue = session.createQueue("MyQueue");
 
// Create a producer for the 'MyQueue'
MessageProducer producer = session.createProducer(queue);

Crie uma mensagem de texto e envie-a para a fila.

Para receber mensagens, crie um consumidor para a mesma fila e invoque o método start.

Você também pode chamar o método start na conexão a qualquer momento. No entanto, o consumidor não começa a receber mensagens até você chamá-lo.

// Create a consumer for the 'MyQueue'
MessageConsumer consumer = session.createConsumer(queue);
// Start receiving incoming messages
connection.start();

Chame o método receive no consumidor com um tempo limite definido como 1 segundo e imprima o conteúdo da mensagem recebida.

Feche a conexão e a sessão.

// Close the connection (and the session).
connection.close();

Implemente a interface MessageListener.

class MyListener implements MessageListener {
 
    @Override
    public void onMessage(Message message) {
        try {
            // Cast the received message as TextMessage and print the text to screen.
            System.out.println("Received: " + ((TextMessage) message).getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

O método onMessage da interface MessageListener é chamado quando você recebe uma mensagem. Nesta implementação de listener, o texto armazenado na mensagem é impresso.

Em vez de explicitamente chamar o método receive no consumidor, defina o listener da mensagem do consumidor como uma instância da implementação MyListener. O thread principal aguarda um segundo.

// Create a consumer for the 'MyQueue'.
MessageConsumer consumer = session.createConsumer(queue);
 
// Instantiate and set the message listener for the consumer.
consumer.setMessageListener(new MyListener());
 
// Start receiving incoming messages.
connection.start();
 
// Wait for 1 second. The listener onMessage() method is invoked when a message is received.
Thread.sleep(1000);

Para explicitamente reconhecer as mensagens depois de processadas, você deve criar a sessão com o modo CLIENT_ACKNOWLEDGE.

// Create the non-transacted session with CLIENT_ACKNOWLEDGE mode.
Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);

Quando a mensagem é recebida, exiba-a e confirme-a explicitamente.

// Cast the received message as TextMessage and print the text to screen. Also acknowledge the message.
if (receivedMessage != null) {
    System.out.println("Received: " + ((TextMessage) receivedMessage).getText());
    receivedMessage.acknowledge();
    System.out.println("Acknowledged: " + message.getJMSMessageID());
}