В этой статье мы предоставляем краткое руководство по очистке кэша memoryIdempotentRepositoryв приложении Apache Camel.
Корпоративный шаблон интеграции (EIP), IdempotentConsumerреализованный Apache Camel, отфильтровывает дублирующиеся обменные сообщения. Этот процесс требует кеша. Верблюд реализует различные виды кэша, такие как MemoryIdempotentRepository[1].
Это MemoryIdempotentRepository очень быстрое хранилище в памяти, которое хранит записи в структуре карты. Данные будут потеряны, когда JVM выключится. Однако может случиться так, что вы захотите удалить кеш до или без выключения JVM.
Для очистки кеша вы можете использовать clear()определенные в MemoryIdempotentRepository.java .
Следующий процессор очищает MemoryIdempotentRepository(здесь с именем TEMP_CACHE):
Джава
1
.process(new Processor() {
2
3
public void process(Exchange exchange) throws Exception {
4
TEMP_CACHE.clear();
5
}
6
})
[1] https://camel.apache.org/manual/latest/idempotentConsumer-eip.html ..