使用Spring cloud SqsListener读取消息失败的尝试之间的阈值

问题描述 投票:0回答:1

在我的Spring-Boot 2应用程序中有一个SqsListener

@SqsListener(value = "${sqs.message.queue}", deletionPolicy = ON_SUCCESS)
public void myMessageListener(MyMessage myMessage) throws MyMessageServiceException {
    myMessageService.processMessage(myMessage);
}

MyMessageService#processMessage在某些情况下会引发异常。完成后,该消息将根据deletionPolicy的命令返回SQS,以由上述侦听器再次读取。]

我希望在处理消息的失败尝试之间有某种阈值(例如600秒)。

是否有一种开箱即用的解决方案来设置这种阈值,而不创建任何断路器逻辑?

在我的Spring-Boot 2应用程序中,有一个SqsListener:@SqsListener(value =“ $ {sqs.message.queue}”,deletePolicy = ON_SUCCESS)public void myMessageListener(MyMessage myMessage)抛出...

java spring-boot listener spring-cloud amazon-sqs
1个回答
0
投票

[我想出的唯一“无代码”解决方案是在Amazon SQS管理控制台的SQS队列设置中更改Default visibility timeout属性。

© www.soinside.com 2019 - 2024. All rights reserved.