SQS: Duplicidade de mensagens na fila

Evitar mensagens duplicadas na fila pode ser um requisito básico para o modelo do seu negócio. A SQS possui um recurso de "desduplicação" de mensagens bem interessante.

Este recurso está presente apenas em filas do tipo FIFO

Existe duas formas de configurar:

1. Na configuração da fila, habilite a opção Desduplicação baseada em conteúdo

2. Uma outra forma de configurar seria no ato do envio da mensagem. Neste caso a fila não precisa ser configurada conforme o item 1.

Segue um trecho de código Java utilizando a SDK da AWS que exemplifica este cenário:

AmazonSQS amazonSQS = AmazonSQSClientBuilder.standard()
        .withRegion(Regions.US_EAST_1)
        .build();

SendMessageRequest messageRequest = new SendMessageRequest();
messageRequest.setMessageBody("mensagem");
messageRequest.setMessageGroupId("id-grupo");
messageRequest.setMessageDeduplicationId("id-desduplicação");
messageRequest.setQueueUrl("url-da-fila");
amazonSQS.sendMessage(messageRequest);

Neste caso é necessário atribuir um ID que identifica a mensagem como duplicada, conforme o trecho:

messageRequest.setMessageDeduplicationId("id-desduplicação");

O código descrito no item 2 pode ser utilizado para o item 1, mas nesse caso, o trecho anterior é opcional.

Ponto de atenção

Este recurso só funciona quando mensagens de mesmo conteúdo são enviadas em um intervalo de até 5 minutos. Caso o intervalo entre elas seja maior que 5 minutos, a fila receberá a mensagem duplicada.