SQS java config

JMSSQSConfig.java

import com.amazon.sqs.javamessaging.SQSConnectionFactory;
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.listener.DefaultMessageListenerContainer;

@Configuration
public class JMSSQSConfig {

    private final String endpoint;
    private final String queueName;
    private final AWSCredentialsProvider awsCredentialsProvider;
    private final SQSListener sqsListener;

    @Autowired
    public JMSSQSConfig(@Value("${queue.endpoint}") String endpoint, @Value("${queue.name}") String queueName,
                        AWSCredentialsProvider awsCredentialsProvider, SQSListener sqsListener) {
        this.endpoint = endpoint;
        this.queueName = queueName;
        this.awsCredentialsProvider = awsCredentialsProvider;
        this.sqsListener = sqsListener;
    }

    @Bean
    public DefaultMessageListenerContainer jmsListenerContainer() {

        SQSConnectionFactory sqsConnectionFactory = SQSConnectionFactory.builder()
                .withAWSCredentialsProvider(new DefaultAWSCredentialsProviderChain())
                .withEndpoint(endpoint)
                .withAWSCredentialsProvider(awsCredentialsProvider)
                .withNumberOfMessagesToPrefetch(10).build();

        DefaultMessageListenerContainer dmlc = new DefaultMessageListenerContainer();
        dmlc.setConnectionFactory(sqsConnectionFactory);
        dmlc.setDestinationName(queueName);
        dmlc.setMessageListener(sqsListener);

        return dmlc;
    }

}

MessageService.java

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;


@Service
public class MessageService {

    private final JmsTemplate jmsTemplate;
    private final String queueName;

    @Autowired
    public MessageService(JmsTemplate jmsTemplate, @Value("${queue.name}") String queueName) {
        this.jmsTemplate = jmsTemplate;
        this.queueName = queueName;
    }

    public void sendMessage(final String message) {
        jmsTemplate.send(queueName, session -> session.createTextMessage(message));
    }

}

SQSListener.java

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;


@Component
public class SQSListener implements MessageListener {

    private static final Logger LOGGER = LoggerFactory.getLogger(SQSListener.class);
    private final DatabaseSelector databaseSelector;

    @Autowired
    public SQSListener(DatabaseSelector databaseSelector) {
        this.databaseSelector = databaseSelector;
    }

    public void onMessage(Message message) {
        try {
            TextMessage textMessage = (TextMessage) message;
            LOGGER.info("Received message " + textMessage.getText());
            databaseSelector.toggle();
            LOGGER.info("current db is:" + databaseSelector.getCurrent());
        } catch (JMSException e) {
            throw new RuntimeException(e);
        }
    }
}

https://aws.amazon.com/blogs/developer/using-amazon-sqs-with-spring-boot-and-spring-jms/
http://yamenali.blogspot.com.au/2016/11/amazon-sqs-with-spring-java-framework.html

https://egkatzioura.com/2016/02/27/aws-sqs-and-spring-jms-integration/