聚合后的Exchange完成 [英] Completion of Exchange once Aggregated

问题描述

我正在从Rabb中提取消息并将其聚合。我注意到，即使在AutoAck=False的情况下，消息一旦聚合就会被确认。这意味着如果我的进程崩溃，消息将不会重新排队等待Rty。

我已经插入了Levdb Java数据库作为聚合repo，它解决了这个问题，因为我假设它只有在聚合并存储到repo中后才会确认？老实说，基于它的活动和C版本的问题，Level-db让我感觉不舒服，我想我可以将它切换到SQL repo。

所以。问题是，有没有什么我可以做的，这样Camel只会在聚合消息完成其旅程后才接受交换的消息？聚合之后，我的下一步是简单地写入磁盘。

推荐答案

也就是设计，那么聚合器就是有状态弹性公网IP。因此，传入的消息被移交给聚合器，然后继续，这样，处理消息的兔子消费者就完成了，并被确认了。

如您所说，您需要插入一个永久聚合存储库。

因为您的最后一步是写入磁盘，所以我会重新设计，这样您就可以先从兔子那里获取每条消息并写入磁盘，然后再从磁盘->Aggregate->Disk执行另一步操作。

这篇关于聚合后的Exchange完成的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！