Spring-cloud-aws: Is there any support to have multiple SimpleMessageListenerContainerFactory

[tmnuwan12]

Question:

Is there any possibility we can run multiple SimpleMessageListenerContainerFactory?

My use-case is I have Fifo queue in one region and standard queue in another region. I need to listen to both of these queues in the same application. How can I do this? Please help.

[tmnuwan12]

https://github.com/spring-cloud/spring-cloud-aws/issues/78#issuecomment-129043213

With the above inspiration you can write your custom resolver.

Please see the below class:

public class DynamicFifoQueueUrlDestinationResolver extends DynamicQueueUrlDestinationResolver {

    private AmazonSQSAsync fifoSQS;

    private boolean autoCreate;
    private final AmazonSQS amazonSqs;
    private final ResourceIdResolver resourceIdResolver = null;

    /**
     * @param amazonSqs
     */
    public DynamicFifoQueueUrlDestinationResolver(AmazonSQS amazonSqs, AmazonSQSAsync fifo) {
        super(amazonSqs);
        this.amazonSqs = amazonSqs;
        this.fifoSQS = fifo;
    }

    // quick hack
    @Override
    public String resolveDestination(String name) throws DestinationResolutionException {
        String queueName = name;

        if (this.resourceIdResolver != null) {
            queueName = this.resourceIdResolver.resolveToPhysicalResourceId(name);
        }

        if (isValidQueueUrl(queueName)) {
            return queueName;
        }

        if (this.autoCreate) {

            if (name.contains(Queues.FIFO.name())) {
                // Auto-create is fine to be called even if the queue exists.
                CreateQueueResult createQueueResult = this.fifoSQS.createQueue(new CreateQueueRequest(name));
                return createQueueResult.getQueueUrl();
            } else {
                // Auto-create is fine to be called even if the queue exists.
                CreateQueueResult createQueueResult = this.amazonSqs.createQueue(new CreateQueueRequest(name));
                return createQueueResult.getQueueUrl();
            }
        } else {

            if (name.contains(Queues.FIFOQUEUE.name())) {

                try {
                    GetQueueUrlResult getQueueUrlResult = this.fifoSQS.getQueueUrl(new GetQueueUrlRequest(name));
                    return getQueueUrlResult.getQueueUrl();
                } catch (QueueDoesNotExistException e) {
                    throw new DestinationResolutionException(e.getMessage(), e);
                }
            } else {
                try {
                    GetQueueUrlResult getQueueUrlResult = this.amazonSqs.getQueueUrl(new GetQueueUrlRequest(name));
                    return getQueueUrlResult.getQueueUrl();
                } catch (QueueDoesNotExistException e) {
                    throw new DestinationResolutionException(e.getMessage(), e);
                }
            }
        }

    }

    private static boolean isValidQueueUrl(String name) {
        try {
            URI candidate = new URI(name);
            return ("http".equals(candidate.getScheme()) || "https".equals(candidate.getScheme()));
        } catch (URISyntaxException e) {
            return false;
        }
    }

    public void setAutoCreate(boolean autoCreate) {
        this.autoCreate = autoCreate;
    }

}

[tmnuwan12]

It would be great if Spring boot can provide this out of the box.