我将 infinispan9 与骆驼 infispan.xml 一起使用
<distributed-cache name="myCache" mode="SYNC" start="EAGER">
<locking isolation="READ_COMMITTED" acquire-timeout="30000" concurrency-level="1000" striping="false"/>
<!-- set lifespan to 1 hour in millisecond 3600000-->
<expiration lifespan="120000" />
</distributed-cache>
在我的骆驼路线中,我正在使用:
<idempotentConsumer messageIdRepositoryRef="infinispanRepo">
<header>CamelFileName</header>
<setHeader headerName="fileExist">
<simple>true</simple>
</setHeader>
</idempotentConsumer>
<when>
<simple>${header.fileExist} == null</simple>
<!-- log duplicate-->
</when>
现在我担心的是我在 6:30:00 处理了一个文件,它处理成功。我在 6:31:00 重新处理了文件,它记录了重复。没关系。我希望文件在 6:32:00 之后成功重新处理,但失败并记录重复。我观察到的是,当 idempotentConsumer 正在验证时,时间会更新,我需要在最后处理的重复日志后等待 2 秒。
我想要的只是在第一次进入后过期。请帮忙。