Camel idempotentConsumer总是使用PUT而不是GET

问题描述 投票:0回答:1

我正在使用骆驼幂等。有人可以解释一下idempotentConsumer xml标签背后的逻辑。

我第一次收到文件。所有好的idempotentconsumer块都被执行了。在infinispan服务器上我看到一个日志PUT。

我删除了一个重复的文件。现在,idempotentconsumer识别重复但在infinispan服务器上我看到一个带PUT而不是GET的日志。我想知道服务器端或camel-client的这个问题?

<idempotentConsumer messageIdRepositoryRef="infinispanRepo" >
<header>CamelFileAbsolutePath</header>
</idempotentConsumer>
apache-camel
1个回答
0
投票

不,这是按设计工作的。幂等消费者EIP将尝试使用固定值true将密钥放入缓存 - 这将是Infinispan上的原子操作。然后使用该put操作的结果来知道是否存在重复。

如果你使用GET执行两个操作然后PUT它不再是原子操作,你最终可能会遇到问题。

请参阅以下代码:https://github.com/apache/camel/blob/master/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/processor/idempotent/InfinispanIdempotentRepository.java#L68

© www.soinside.com 2019 - 2024. All rights reserved.