org.springframework.integration.mongodb.store

Class ConfigurableMongoDbMessageStore

java.lang.Object

org.springframework.integration.store.AbstractMessageGroupStore

org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore

All Implemented Interfaces:

Iterable<MessageGroup>, Aware, BeanFactoryAware, InitializingBean, ApplicationContextAware, BasicMessageGroupStore, MessageGroupStore, MessageStore

public class ConfigurableMongoDbMessageStore
extends AbstractMessageGroupStore
implements MessageStore, InitializingBean, ApplicationContextAware

An alternate MongoDB MessageStore and MessageGroupStore which allows the user to configure the instance of MongoTemplate. The mechanism of storing the messages/group of messages in the store is and is different from MongoDbMessageStore. Since the store uses serialization of the messages by default, all the headers, and the payload of the Message must implement Serializable interface

Since:

3.0

Author:

Amol Nayak, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.store.MessageGroupStore

MessageGroupStore.MessageGroupCallback

Field Summary

Fields

Modifier and Type	Field and Description
static String	CREATED_DATE_KEY The name of the message header that stores a timestamp for the time the message was inserted.
static String	DEFAULT_COLLECTION_NAME
static String	SAVED_KEY The name of the message header that stores a flag to indicate that the message has been saved.

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

logger

Constructor Summary

Constructors

Constructor and Description
ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory)
ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter)
ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, String collectionName)
ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory, String collectionName)
ConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate)
ConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, String collectionName)

Method Summary

Methods

Modifier and Type	Method and Description
<T> Message<T>	addMessage(Message<T> message) Put the provided Message into the MessageStore.
MessageGroup	addMessageToGroup(Object groupId, Message<?> message) Store a message with an association to a group id.
void	afterPropertiesSet()
void	completeGroup(Object groupId) Completes this MessageGroup.
Message<?>	getMessage(UUID id)
long	getMessageCount() Optional attribute giving the number of messages in the store.
MessageGroup	getMessageGroup(Object groupId) Return all Messages currently in the MessageStore that were stored using BasicMessageGroupStore.addMessageToGroup(Object, Message) with this group id.
Iterator<MessageGroup>	iterator()
int	messageGroupSize(Object groupId) Returns the size of this MessageGroup.
Message<?>	pollMessageFromGroup(Object groupId) Polls Message from this MessageGroup (in FIFO style if supported by the implementation) while also removing the polled Message
Message<?>	removeMessage(UUID id) Remove the Message with the given id from the MessageStore, if present, and return it.
MessageGroup	removeMessageFromGroup(Object groupId, Message<?> messageToRemove) Persist a deletion on a single message from the group.
void	removeMessageGroup(Object groupId) Remove the message group with this id.
void	setApplicationContext(ApplicationContext applicationContext)
void	setLastReleasedSequenceNumberForGroup(Object groupId, int sequenceNumber) Allows you to set the sequence number of the last released Message.

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_COLLECTION_NAME

public static final String DEFAULT_COLLECTION_NAME

See Also:

Constant Field Values

SAVED_KEY

public static final String SAVED_KEY

The name of the message header that stores a flag to indicate that the message has been saved. This is an optimization for the put method.

CREATED_DATE_KEY

public static final String CREATED_DATE_KEY

The name of the message header that stores a timestamp for the time the message was inserted.

Constructor Detail

ConfigurableMongoDbMessageStore

public ConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate)

ConfigurableMongoDbMessageStore

public ConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate,
                               String collectionName)

ConfigurableMongoDbMessageStore

public ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory)

ConfigurableMongoDbMessageStore

public ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory,
                               MappingMongoConverter mappingMongoConverter)

ConfigurableMongoDbMessageStore

public ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory,
                               String collectionName)

ConfigurableMongoDbMessageStore

public ConfigurableMongoDbMessageStore(MongoDbFactory mongoDbFactory,
                               MappingMongoConverter mappingMongoConverter,
                               String collectionName)

Method Detail

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

getMessage

public Message<?> getMessage(UUID id)

Specified by:

getMessage in interface MessageStore

Parameters:

id - The message identifier.

Returns:

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

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

Type Parameters:

T - The payload type.

Parameters:

message - The message.

Returns:

The message that was stored.

removeMessage

public Message<?> removeMessage(UUID id)

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

Parameters:

id - THe message identifier.

Returns:

The message.

getMessageCount

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.

messageGroupSize

public int messageGroupSize(Object groupId)

Description copied from interface: BasicMessageGroupStore

Returns the size of this MessageGroup.

Specified by:

messageGroupSize in interface BasicMessageGroupStore

Parameters:

groupId - The group identifier.

Returns:

The size.

getMessageGroup

public MessageGroup getMessageGroup(Object groupId)

Description copied from interface: BasicMessageGroupStore

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

Specified by:

getMessageGroup in interface BasicMessageGroupStore

Parameters:

groupId - The group identifier.

Returns:

A group of messages, empty if none exists for this key.

addMessageToGroup

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

Description copied from interface: BasicMessageGroupStore

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

Specified by:

addMessageToGroup in interface BasicMessageGroupStore

Parameters:

groupId - The group id to store the message under.

message - A message.

Returns:

The message group.

removeMessageFromGroup

public MessageGroup removeMessageFromGroup(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.

Returns:

The message Group.

removeMessageGroup

public void removeMessageGroup(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.

iterator

public Iterator<MessageGroup> iterator()

Specified by:

iterator in interface Iterable<MessageGroup>

Specified by:

iterator in interface MessageGroupStore

Returns:

The iterator of currently accumulated MessageGroups.

pollMessageFromGroup

public Message<?> pollMessageFromGroup(Object groupId)

Description copied from interface: BasicMessageGroupStore

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

Specified by:

pollMessageFromGroup in interface BasicMessageGroupStore

Parameters:

groupId - The group identifier.

Returns:

The message.

setLastReleasedSequenceNumberForGroup

public void setLastReleasedSequenceNumberForGroup(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

Parameters:

groupId - The group identifier.

sequenceNumber - The sequence number.

completeGroup

public void completeGroup(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

Parameters:

groupId - The group identifier.