Spring集成——消息存储是否可以持久化到队列



问题:如何在系统发生故障时将Message Store中的消息回滚回队列?

Scenerio: IBM MQ队列——> JMS消息驱动通道适配器——>聚合器。

在导致JVM关闭的系统故障期间。除了使用默认的易变消息存储,我是否可以指定MQ队列作为持久消息存储?这样,如果发生系统故障,可以将消息存储中的消息回滚到MQ持久队列以进行故障转移处理。

编辑:最后一句澄清。

我不清楚你说的…是什么意思

可以回滚到原始队列

…如果你的意思是自动的,那就不是。

有一个JDBC消息存储实现(但你需要XA事务)。

您可能可以创建一个由JMS支持的自定义消息存储,但这是队列的一种不寻常的使用-我认为您必须使用基于groupId的消息选择器,但您可能必须在内存中保留一个镜像(并在系统初始化期间对其进行初始化,同时将消息留在队列中)。

最新更新