Polling Consumer no SQS com Apache Camel

Este cliente tem que ser registrado via JNDI para que fique visível ao componente do Camel.

Logo após podemos criar nosso Contexto para que nossas rotas possam ser executadas.

Iremos criar nossas rotas usando a DSL que o Camel disponibiliza para não ter que usar XML.

Explicando um pouco mais a DSL, basicamente, estou passando o padrão de URI do Camel (aws-sqs://queue-name```?options )

amazonSQSClient: Parêmetro que foi registrado via JNDI.  Com isso o componente vai conseguir se conectar ao SQS e fazer o consumo da fila.

Vale lembrar que temos que passar o # antes do nome registrado.

deleteIfFiltered: Esse parâmetro é importante, pois, diferentemente de outros MOM, o SQS não faz FIFO (First In First Out) e a responsabilidade de remover a mensagem é totalmente sua.

Agora é adicionar essa rota ao nosso contexto e testar. Não esqueça que para esse exemplo funcionar você precisa configurar seu ambiente na Amazon.

Você pode entender melhor a DSL do Camel com outro artigo publicado aqui. E ler todas as opções que você tem para usar na rota do SQS aqui.

Se está usando Maven, precisará das dependências do SQS e do SDK da Amazon.

Você também vai precisar configurar seu contexto JNDI. Crie um arquivo chamado. jndi.properties com o seguinte conteudo.

O projeto completo você pode encontrar no meu Github.