Uses of Interface
org.apache.camel.spi.IdempotentRepository

Packages that use IdempotentRepository

org.apache.camel.component.file	The File Component for working with file systems.
org.apache.camel.model	The JAXB POJOs for the XML Configuration of the routing rules.
org.apache.camel.processor.idempotent	An implementation of the Idempotent Consumer pattern.

Uses of IdempotentRepository in org.apache.camel.component.file

Fields in org.apache.camel.component.file declared as IdempotentRepository

protected IdempotentRepository<String>	GenericFileEndpoint.idempotentRepository
protected IdempotentRepository<String>	GenericFileEndpoint.inProgressRepository

Methods in org.apache.camel.component.file that return IdempotentRepository

IdempotentRepository<String>	GenericFileEndpoint.getIdempotentRepository()
IdempotentRepository<String>	GenericFileEndpoint.getInProgressRepository()

Methods in org.apache.camel.component.file with parameters of type IdempotentRepository

void	GenericFileEndpoint.setIdempotentRepository(IdempotentRepository<String> idempotentRepository)
void	GenericFileEndpoint.setInProgressRepository(IdempotentRepository<String> inProgressRepository)

Uses of IdempotentRepository in org.apache.camel.model

Methods in org.apache.camel.model that return IdempotentRepository

IdempotentRepository<?>	IdempotentConsumerDefinition.getMessageIdRepository()
protected IdempotentRepository<?>	IdempotentConsumerDefinition.resolveMessageIdRepository(RouteContext routeContext) Strategy method to resolve the IdempotentRepository to use

Methods in org.apache.camel.model with parameters of type IdempotentRepository

IdempotentConsumerDefinition	ProcessorDefinition.idempotentConsumer(Expression messageIdExpression, IdempotentRepository<?> idempotentRepository) Idempotent consumer EIP: Creates an IdempotentConsumer to avoid duplicate messages
ExpressionClause<IdempotentConsumerDefinition>	ProcessorDefinition.idempotentConsumer(IdempotentRepository<?> idempotentRepository) Deprecated. will be removed in Camel 3.0. Instead use any of the other methods
IdempotentConsumerDefinition	IdempotentConsumerDefinition.messageIdRepository(IdempotentRepository<?> idempotentRepository) Sets the the message id repository for the idempotent consumer
void	IdempotentConsumerDefinition.setMessageIdRepository(IdempotentRepository<?> idempotentRepository)

Constructors in org.apache.camel.model with parameters of type IdempotentRepository

IdempotentConsumerDefinition(Expression messageIdExpression, IdempotentRepository<?> idempotentRepository)

Uses of IdempotentRepository in org.apache.camel.processor.idempotent

Classes in org.apache.camel.processor.idempotent that implement IdempotentRepository

class	FileIdempotentRepository A file based implementation of IdempotentRepository.
class	MemoryIdempotentRepository A memory based implementation of IdempotentRepository.

Methods in org.apache.camel.processor.idempotent that return IdempotentRepository

static IdempotentRepository<String>	FileIdempotentRepository.fileIdempotentRepository(File fileStore) Creates a new file based repository using a LRUCache as 1st level cache with a default of 1000 entries in the cache.
static IdempotentRepository<String>	FileIdempotentRepository.fileIdempotentRepository(File fileStore, int cacheSize) Creates a new file based repository using a LRUCache as 1st level cache.
static IdempotentRepository<String>	FileIdempotentRepository.fileIdempotentRepository(File fileStore, int cacheSize, long maxFileStoreSize) Creates a new file based repository using a LRUCache as 1st level cache.
static IdempotentRepository<String>	FileIdempotentRepository.fileIdempotentRepository(File store, Map<String,Object> cache) Creates a new file based repository using the given Map as 1st level cache.
IdempotentRepository<String>	IdempotentConsumer.getIdempotentRepository()
static IdempotentRepository<String>	MemoryIdempotentRepository.memoryIdempotentRepository() Creates a new memory based repository using a LRUCache with a default of 1000 entries in the cache.
static IdempotentRepository<String>	MemoryIdempotentRepository.memoryIdempotentRepository(int cacheSize) Creates a new memory based repository using a LRUCache.
static IdempotentRepository<String>	MemoryIdempotentRepository.memoryIdempotentRepository(Map<String,Object> cache) Creates a new memory based repository using the given Map to use to store the processed message ids.

Constructors in org.apache.camel.processor.idempotent with parameters of type IdempotentRepository

IdempotentConsumer(Expression messageIdExpression, IdempotentRepository<String> idempotentRepository, boolean eager, boolean skipDuplicate, boolean removeOnFailure, Processor processor)

IdempotentOnCompletion(IdempotentRepository<String> idempotentRepository, String messageId, boolean eager, boolean removeOnFailure)