org.springframework.integration.store
Class SimpleMessageStore

java.lang.Object
  org.springframework.integration.store.AbstractMessageGroupStore
      org.springframework.integration.store.SimpleMessageStore

All Implemented Interfaces:

java.lang.Iterable<MessageGroup>, MessageGroupStore, MessageStore

@ManagedResource
public class SimpleMessageStore
extends AbstractMessageGroupStore
implements MessageStore, MessageGroupStore

Map-based in-memory implementation of MessageStore and MessageGroupStore. Enforces a maximum capacity for the store.

Since:

2.0

Author:

Iwein Fuld, Mark Fisher, Dave Syer, Oleg Zhurakousky, Gary Russell

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.

SimpleMessageStore(int individualCapacity, int groupCapacity, LockRegistry lockRegistry)
See SimpleMessageStore(int, int).

Method Summary

<T> Message<T>	addMessage(Message<T> message) Put the provided Message into the MessageStore.
MessageGroup	addMessageToGroup(java.lang.Object groupId, Message<?> message) Store a message with an association to a group id.
void	completeGroup(java.lang.Object groupId) Completes this MessageGroup.
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.
long	getMessageCount() Optional attribute giving the number of messages in the store.
MessageGroup	getMessageGroup(java.lang.Object groupId) Return all Messages currently in the MessageStore that were stored using MessageGroupStore.addMessageToGroup(Object, Message) with this group id.
java.util.Iterator<MessageGroup>	iterator() Returns the iterator of currently accumulated MessageGroups
int	messageGroupSize(java.lang.Object groupId) Returns the size of this MessageGroup
Message<?>	pollMessageFromGroup(java.lang.Object groupId) Polls Message from this MessageGroup (in FIFO style if supported by the implementation) while also removing the polled Message
Message<?>	removeMessage(java.util.UUID key) Remove the Message with the given id from the MessageStore, if present, and return it.
MessageGroup	removeMessageFromGroup(java.lang.Object groupId, Message<?> messageToRemove) Persist a deletion on a single message from the group.
void	removeMessageGroup(java.lang.Object groupId) Remove the message group with this id.
void	setLastReleasedSequenceNumberForGroup(java.lang.Object groupId, int sequenceNumber) Allows you to set the sequence number of the last released Message.
void	setLockRegistry(LockRegistry lockRegistry)

Methods inherited from class org.springframework.integration.store.AbstractMessageGroupStore

expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setExpiryCallbacks, setTimeoutOnIdle

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, getMessageCountForAllMessageGroups, getMessageGroupCount, registerMessageGroupExpiryCallback

Constructor Detail

SimpleMessageStore

public 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. The capacities are applied independently to messages stored via 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.

SimpleMessageStore

public SimpleMessageStore(int individualCapacity,
                          int groupCapacity,
                          LockRegistry lockRegistry)

See SimpleMessageStore(int, int). Also allows the provision of a custom LockRegistry rather than using the default.

SimpleMessageStore

public SimpleMessageStore(int capacity)

Creates a SimpleMessageStore with the same capacity for individual and grouped messages.

SimpleMessageStore

public SimpleMessageStore()

Creates a SimpleMessageStore with unlimited capacity

Method Detail

setLockRegistry

public void setLockRegistry(LockRegistry lockRegistry)

getMessageCount

@ManagedAttribute
public long getMessageCount()

Description copied from interface: MessageStore

Optional attribute giving the number of messages in the store. Implementations may decline to respond by throwing an exception.

Specified by:

getMessageCount in interface MessageStore

Returns:

the number of messages

addMessage

public <T> Message<T> addMessage(Message<T> message)

Description copied from interface: MessageStore

Put the provided Message into the MessageStore. The store may need to mutate the message internally, and if it does then the return value can be different than the input. The id of the return value will be used as an index so that the MessageStore.getMessage(UUID) and MessageStore.removeMessage(UUID) behave properly. Since messages are immutable, putting the same message more than once is a no-op.

Specified by:

addMessage in interface MessageStore

Returns:

the message that was stored

getMessage

public Message<?> getMessage(java.util.UUID key)

Description copied from interface: MessageStore

Return the Message with the given id, or null if no Message with that id exists in the MessageStore.

Specified by:

getMessage in interface MessageStore

removeMessage

public Message<?> removeMessage(java.util.UUID key)

Description copied from interface: MessageStore

Remove the Message with the given id from the MessageStore, if present, and return it. If no Message with that id is present in the store, this will return null.

Specified by:

removeMessage in interface MessageStore

getMessageGroup

public MessageGroup getMessageGroup(java.lang.Object groupId)

Description copied from interface: MessageGroupStore

Return all Messages currently in the MessageStore that were stored using MessageGroupStore.addMessageToGroup(Object, Message) with this group id.

Specified by:

getMessageGroup in interface MessageGroupStore

Returns:

a group of messages, empty if none exists for this key

addMessageToGroup

public MessageGroup addMessageToGroup(java.lang.Object groupId,
                                      Message<?> message)

Description copied from interface: MessageGroupStore

Store a message with an association to a group id. This can be used to group messages together.

Specified by:

addMessageToGroup in interface MessageGroupStore

Parameters:

groupId - the group id to store the message under

message - a message

removeMessageGroup

public void removeMessageGroup(java.lang.Object groupId)

Description copied from interface: MessageGroupStore

Remove the message group with this id.

Specified by:

removeMessageGroup in interface MessageGroupStore

Parameters:

groupId - the id of the group to remove

removeMessageFromGroup

public MessageGroup removeMessageFromGroup(java.lang.Object groupId,
                                           Message<?> messageToRemove)

Description copied from interface: MessageGroupStore

Persist a deletion on a single message from the group. The group is modified to reflect that 'messageToRemove' is no longer present in the group.

Specified by:

removeMessageFromGroup in interface MessageGroupStore

Parameters:

groupId - the groupId for the group containing the message

messageToRemove - the message to be removed

iterator

public java.util.Iterator<MessageGroup> iterator()

Description copied from interface: MessageGroupStore

Returns the iterator of currently accumulated MessageGroups

Specified by:

iterator in interface java.lang.Iterable<MessageGroup>

Specified by:

iterator in interface MessageGroupStore

setLastReleasedSequenceNumberForGroup

public void setLastReleasedSequenceNumberForGroup(java.lang.Object groupId,
                                                  int sequenceNumber)

Description copied from interface: MessageGroupStore

Allows you to set the sequence number of the last released Message. Used for Resequencing use cases

Specified by:

setLastReleasedSequenceNumberForGroup in interface MessageGroupStore

completeGroup

public void completeGroup(java.lang.Object groupId)

Description copied from interface: MessageGroupStore

Completes this MessageGroup. Completion of the MessageGroup generally means that this group should not be allowing any more mutating operation to be performed on it. For example any attempt to add/remove new Message form the group should not be allowed.

Specified by:

completeGroup in interface MessageGroupStore

pollMessageFromGroup

public Message<?> pollMessageFromGroup(java.lang.Object groupId)

Description copied from interface: MessageGroupStore

Polls Message from this MessageGroup (in FIFO style if supported by the implementation) while also removing the polled Message

Specified by:

pollMessageFromGroup in interface MessageGroupStore

messageGroupSize

public int messageGroupSize(java.lang.Object groupId)

Description copied from interface: MessageGroupStore

Returns the size of this MessageGroup

Specified by:

messageGroupSize in interface MessageGroupStore