|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
GenericFileEndpoint.idempotentRepository
|
protected IdempotentRepository<String> |
GenericFileEndpoint.inProgressRepository
|
Methods in org.apache.camel.component.file that return IdempotentRepository | |
---|---|
IdempotentRepository |
GenericFileEndpoint.getIdempotentRepository()
|
IdempotentRepository<String> |
GenericFileEndpoint.getInProgressRepository()
|
Methods in org.apache.camel.component.file with parameters of type IdempotentRepository | |
---|---|
void |
GenericFileEndpoint.setIdempotentRepository(IdempotentRepository 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)
Idempotent consumer EIP: Creates an IdempotentConsumer
to avoid duplicate messages |
IdempotentConsumerDefinition |
IdempotentConsumerDefinition.messageIdRepository(IdempotentRepository idempotentRepository)
Sets the the message id repository for the IdempotentConsumerType |
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 |
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 idempotentRepository,
boolean eager,
Processor processor)
|
|
IdempotentOnCompletion(IdempotentRepository idempotentRepository,
String messageId,
boolean eager)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |