192.4. 幂等库
如之前提到的,此组件还提供了 和 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");
192.4.1. 另请参阅 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!