|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.SimpleMessageStore
public class SimpleMessageStore
Map-based implementation of MessageStore and MessageGroupStore. Enforces a maximum capacity for the
store.
| Field Summary |
|---|
| Fields inherited from class org.springframework.integration.store.AbstractMessageGroupStore |
|---|
logger |
| Constructor Summary | |
|---|---|
SimpleMessageStore()
Creates a SimpleMessageStore with unlimited capacity |
|
SimpleMessageStore(int capacity)
Creates a SimpleMessageStore with the same capacity for individual and grouped messages. |
|
SimpleMessageStore(int individualCapacity,
int groupCapacity)
Creates a SimpleMessageStore with a maximum size limited by the given capacity, or unlimited size if the given capacity is less than 1. |
|
| Method Summary | ||
|---|---|---|
|
addMessage(Message<T> message)
Put the provided Message into the MessageStore. |
|
void |
addMessageToGroup(java.lang.Object correlationId,
Message<?> message)
Store a message with an association to a correlation key. |
|
Message<?> |
getMessage(java.util.UUID key)
Return the Message with the given id, or null if no Message with that id exists in the MessageStore. |
|
MessageGroup |
getMessageGroup(java.lang.Object correlationId)
Return all Messages currently in the MessageStore that were stored using #addMessageToGroup(Object, Collection) with this correlation id. |
|
java.util.Iterator<MessageGroup> |
iterator()
|
|
void |
markMessageGroup(MessageGroup group)
Persist the mark on all the messages from the group. |
|
Message<?> |
removeMessage(java.util.UUID key)
Remove the Message with the given id from the MessageStore, if present, and return it. |
|
void |
removeMessageGroup(java.lang.Object correlationId)
Remove the message group with this correlation key. |
|
| Methods inherited from class org.springframework.integration.store.AbstractMessageGroupStore |
|---|
expireMessageGroups, registerMessageGroupExpiryCallback, setExpiryCallbacks |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Methods inherited from interface org.springframework.integration.store.MessageGroupStore |
|---|
expireMessageGroups, registerMessageGroupExpiryCallback |
| Constructor Detail |
|---|
public SimpleMessageStore(int individualCapacity,
int groupCapacity)
addMessage(Message) and to those stored via addMessageToGroup(Object, Message). In both cases
the capacity applies to the number of messages that can be stored, and once that limit is reached attempting to
store another will result in an exception.
public SimpleMessageStore(int capacity)
public SimpleMessageStore()
| Method Detail |
|---|
public <T> Message<T> addMessage(Message<T> message)
MessageStoreMessageStore.getMessage(UUID) and MessageStore.removeMessage(UUID) behave properly. Since messages are immutable, putting
the same message more than once is a no-op.
addMessage in interface MessageStorepublic Message<?> getMessage(java.util.UUID key)
MessageStore
getMessage in interface MessageStorepublic Message<?> removeMessage(java.util.UUID key)
MessageStore
removeMessage in interface MessageStorepublic MessageGroup getMessageGroup(java.lang.Object correlationId)
MessageGroupStore#addMessageToGroup(Object, Collection) with this correlation id.
getMessageGroup in interface MessageGroupStore
public void addMessageToGroup(java.lang.Object correlationId,
Message<?> message)
MessageGroupStore
addMessageToGroup in interface MessageGroupStorecorrelationId - the correlation id to store the message undermessage - a messagepublic void markMessageGroup(MessageGroup group)
MessageGroupStore
markMessageGroup in interface MessageGroupStoregroup - a MessageGroup with no unmarked messagespublic void removeMessageGroup(java.lang.Object correlationId)
MessageGroupStore
removeMessageGroup in interface MessageGroupStorecorrelationId - the correlation id to removepublic java.util.Iterator<MessageGroup> iterator()
iterator in interface java.lang.Iterable<MessageGroup>iterator in class AbstractMessageGroupStore
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||