2017-08-16 116 views
0

我们有SQS监听器,如:春云AWS SQS删除策略

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

此队列关联的死信队列配置重驱动的策略。

问题是默认的Spring Cloud AWS实现在轮询它时发送消息并在内部进行连线3处理它的重试,然后失败。

我可以看到有一个SqsMessageDeletionPolicy枚举ALWAYS和ON_SUCCESS值,等等。我无法在任何文档中找到如何更改该队列的QueueAttribute以更改此行为。

有谁知道吗?

+0

标题说:“SAS”。这是一个拼写错误。它的意思是“SQS”。 –

回答

1

似乎是解决方案基本上是使用SQS具体的注解,而不是普通的一个:

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