Spring Cloud AWS (1.0.0.RC2) 中 SimpleMessageListenerContainer 类的当前实现似乎会在消息处理程序完成消息处理并且方法调用返回后自动删除消息。
在我们的应用程序中,我们需要能够处理消息并等待下游队列的异步确认,然后再从 SQS 上游队列中删除消息。就像是
接收SQS消息 -> 处理消息 -> 发布消息到RabbitMQ(线程在此完成)
删除 SQS 消息 <- 我们的应用 <- RabbitMQ 消息成功 Ack(异步)
由于消息确认通过不同的线程异步返回,因此我们需要在检查成功确认后手动从 SQS 删除消息的选项。
理想情况下,SimpleMessageListener 应可配置其运行模式(自动删除或手动删除)。
我们非常希望使用 spring aws 云库(而不是推出我们自己的)来与 SQS 集成,因为它已经负责侦听器容器 bean 生命周期管理。
请告诉我上述建议的功能是否可行,如果可行,何时可以实施和发布。
谢谢。
spring-cloud ×1