0

我将 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 秒。

我想要的只是在第一次进入后过期。请帮忙。

4

0 回答 0