Spring Nuage AWS SQS Politique

Question

Suppression

Nous avons un auditeur SQS, tels que:

@MessageMapping("queueName") 
void listen(String message) { ... } 

Cette file d'attente a une politique configurée avec une redirection de file d'attente lettre morte associée. Le problème est que l'implémentation Spring Cloud AWS par défaut supprime le message lors de l'interrogation et du câblage interne 3 tentatives pour le traiter et échouer par la suite.

Je peux voir qu'il y a une énumération SqsMessageDeletionPolicy avec des valeurs ALWAYS et ON_SUCCESS, parmi d'autres. Je ne peux pas trouver dans une documentation comment je peux changer les QueueAttributes pour cette file d'attente afin de changer ce comportement.

Quelqu'un sait-il?

Answer 1

On dirait que la solution consiste essentiellement à utiliser l'annotation spécifique SQS au lieu du générique:

@SqsListener(value = "queueName", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS) 
void listen(String message) { ... }