Apache Camel：聚合交换完成时完成交换

Question

在我的Apache Camel应用程序中，我有一条非常简单的路线：

from("aws-sqs://...")
    .aggregate(constant(true), new AggregationStrategy())
    .completionSize(100)
    .to("SEND_AGGREGATE_VIA_HTTP");

也就是说，它从AWS SQS获取消息，以100条为一批进行分组，然后通过HTTP发送到某个地方。

与来自SQS的消息的交换在进入聚合阶段时成功完成，此时Sqs消费者将它们从队列中删除。

问题是，聚合的交换可能会出现问题（传递时可能会出错），消息将丢失。我真的希望这些原始交换只有在它们所在的聚合交换也成功完成（传递了一批消息）时才能成功完成（从队列中删除消息）。有办法做到这一点吗？

谢谢。

Answer 1

您可以将删除后读取设置为假，并在将消息发送到 HTTP 终结点后手动删除消息;您可以使用 Bean 或处理器，并通过 AWS 开发工具包库发送正确的 SQS 删除请求。当然，这是一种解决方法，但我没有看到更好的方法。