2017-08-16 136 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) { ... }