0

我使用带有activemq和camel-http的apache camel,在消息发送到端点并且请求失败后,我仍然会丢失队列中的消息。如果请求失败,则消息不丢失是必要的。我怎样才能做到这一点?

<route>
<from uri="activemq://db_record_rows"/>
<to uri="http://localhost:3000" />
</route>
4

1 回答 1

2

您可以将您的消费者标记为已交易,因此它将由您的上下文的交易管理器处理。

from("activemq://db_record_rows?transacted=true")
.to("http://localhost:3000")
于 2019-06-21T16:18:55.340 回答