Spring 当其中一个容器在处理消息时出现故障时,XD 是否会重新处理同一条消息?

Does Spring XD re-process the same message when one of it's container goes down while processing the message?

应用程序数据流: JSon Messages--> Active MQ --> Spring XD-- Business Login(Transform JSon to Java Object)--> Save Data to Target DB-->数据库

问题:

Sprin-Xd 运行 集群模式,配置了 Radis。

Spring XD 从活动消息队列 (AMQ) 中获取消息。所以消息不再在 AMQ 中。现在,当使用某些业务逻辑处理此消息的容器之一突然关闭时。在这种情况下-

  1. Spring-XD 框架会自动重新处理该特定消息吗?这背后的机制是什么?

谢谢,

阿比

不使用 Redis 传输; Redis 没有支持这种要求的基础设施("transactional" 读取)。您需要使用 rabbit 或 kafka 传输。

编辑:

Application Configuration (scroll down to RabbitMQ) and Message Bus Configuration

具体来说,默认的 ackModeAUTO,这意味着消息在成功时被确认。