193.5. 幂等库
如之前提到的,此组件还提供了 和 idemptonet 存储库,可用于过滤重复的信息。
from("direct://in").idempotentConsumer(header("messageId"), new KratiIdempotentRepositroy("/tmp/idempotent").to("log://out");
from("direct://in").idempotentConsumer(header("messageId"), new KratiIdempotentRepositroy("/tmp/idempotent").to("log://out");