|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.processor.idempotent.MemoryMessageIdRepository
public class MemoryMessageIdRepository
A memory based implementation of MessageIdRepository
. Care should be
taken to use a suitable underlying Map
to avoid this class being a
memory leak
Constructor Summary | |
---|---|
MemoryMessageIdRepository(Map set)
|
Method Summary | |
---|---|
boolean |
contains(String messageId)
Returns true if this messageId has been processed before otherwise this messageId is added to the repository and false is returned. |
static MessageIdRepository |
memoryMessageIdRepository()
Creates a new MemoryMessageIdRepository with a memory based respository. |
static MessageIdRepository |
memoryMessageIdRepository(int cacheSize)
Creates a new MemoryMessageIdRepository with a memory based respository. |
static MessageIdRepository |
memoryMessageIdRepository(Map cache)
Creates a new MemoryMessageIdRepository using the given Map to
use to store the processed Message ID objects. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MemoryMessageIdRepository(Map set)
Method Detail |
---|
public static MessageIdRepository memoryMessageIdRepository()
public static MessageIdRepository memoryMessageIdRepository(int cacheSize)
public static MessageIdRepository memoryMessageIdRepository(Map cache)
Map
to
use to store the processed Message ID objects. Warning be cafeful of the
implementation of Map you use as if you are not careful it could be a
memory leak.
public boolean contains(String messageId)
MessageIdRepository
contains
in interface MessageIdRepository
messageId
- the String ID of the message
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |