2017-08-16 15 views
0

私たちのような、SQSリスナーを持っている:このキューは、関連付けられ不能キューを使用して設定リドライブポリシーを持って春クラウドAWS SQS削除ポリシー

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

問題は、デフォルトのSpring Cloud AWS実装では、メッセージをポーリングするときにメッセージを削除し、その処理のために内部で3回の再試行を行い、後で失敗することです。

特に、ALWAYS値とON_SUCCESS値を持つSqsMessageDeletionPolicy列挙があることがわかります。どんなドキュメンテーションでも、この動作を変更するためにキューのQueueAttributesを変更する方法を見つけることができません。

誰も知っていますか?

+0

タイトルは「SAS」と言います。スペルミスです。それは「SQS」を意味していました。 –

答えて

1

解決策ではなく、一般的な1のSQS特定のアノテーションを使用することが基本的であるように思える:

@SqsListener(value = "queueName", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS) 
void listen(String message) { ... } 
関連する問題