|
|||||||||
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)
MessageStore
MessageStore.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 MessageStore
public Message<?> getMessage(java.util.UUID key)
MessageStore
getMessage
in interface MessageStore
public Message<?> removeMessage(java.util.UUID key)
MessageStore
removeMessage
in interface MessageStore
public 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 MessageGroupStore
correlationId
- the correlation id to store the message undermessage
- a messagepublic void markMessageGroup(MessageGroup group)
MessageGroupStore
markMessageGroup
in interface MessageGroupStore
group
- a MessageGroup with no unmarked messagespublic void removeMessageGroup(java.lang.Object correlationId)
MessageGroupStore
removeMessageGroup
in interface MessageGroupStore
correlationId
- 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 |