Infinispan9 срок годности с верблюдом

Я использую 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 секунды после последнего обработанного дублированного журнала.

Все, что я хочу, это истечь после первой записи. Пожалуйста помоги.

0 ответов

Другие вопросы по тегам