org.springframework.integration.mongodb.store

Class AbstractConfigurableMongoDbMessageStore

java.lang.Object

org.springframework.integration.store.AbstractBatchingMessageGroupStore

org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, BasicMessageGroupStore

Direct Known Subclasses:

ConfigurableMongoDbMessageStore, MongoDbChannelMessageStore

public abstract class AbstractConfigurableMongoDbMessageStore
extends AbstractBatchingMessageGroupStore
implements BasicMessageGroupStore, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware

The abstract MongoDB BasicMessageGroupStore implementation to provide configuration for common options for implementations of this class.

Since:

4.0

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.context.ApplicationContext	applicationContext
protected java.lang.String	collectionName
static java.lang.String	CREATED_DATE_KEY The name of the message header that stores a timestamp for the time the message was inserted.
protected org.apache.commons.logging.Log	logger
protected org.springframework.data.mongodb.core.convert.MappingMongoConverter	mappingMongoConverter
protected MessageBuilderFactory	messageBuilderFactory
protected org.springframework.data.mongodb.MongoDbFactory	mongoDbFactory
protected org.springframework.data.mongodb.core.MongoTemplate	mongoTemplate
static java.lang.String	SAVED_KEY The name of the message header that stores a flag to indicate that the message has been saved.
static java.lang.String	SEQUENCE_NAME

Constructor Summary

Constructors

Constructor and Description
AbstractConfigurableMongoDbMessageStore(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory, org.springframework.data.mongodb.core.convert.MappingMongoConverter mappingMongoConverter, java.lang.String collectionName)
AbstractConfigurableMongoDbMessageStore(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory, java.lang.String collectionName)
AbstractConfigurableMongoDbMessageStore(org.springframework.data.mongodb.core.MongoTemplate mongoTemplate, java.lang.String collectionName)

Method Summary

Modifier and Type	Method and Description
protected void	addMessageDocument(MessageDocument document)
void	afterPropertiesSet()
org.springframework.messaging.Message<?>	getMessage(java.util.UUID id)
protected int	getNextId() Perform MongoDB INC operation for the document, which contains the MessageDocument sequence, and return the new incremented value for the new MessageDocument.
protected static org.springframework.data.mongodb.core.query.Query	groupIdQuery(java.lang.Object groupId)
int	messageGroupSize(java.lang.Object groupId) Returns the size of this MessageGroup.
void	removeMessageGroup(java.lang.Object groupId) Remove the message group with this id.
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

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

getRemoveBatchSize, setRemoveBatchSize

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.BasicMessageGroupStore

addMessageToGroup, getMessageGroup, pollMessageFromGroup

Field Detail

SEQUENCE_NAME

public static final java.lang.String SEQUENCE_NAME

See Also:

Constant Field Values

SAVED_KEY

public static final java.lang.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.

See Also:

Constant Field Values

CREATED_DATE_KEY

public static final java.lang.String CREATED_DATE_KEY

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

See Also:

Constant Field Values

logger

protected final org.apache.commons.logging.Log logger

collectionName

protected final java.lang.String collectionName

mongoDbFactory

protected final org.springframework.data.mongodb.MongoDbFactory mongoDbFactory

mongoTemplate

protected org.springframework.data.mongodb.core.MongoTemplate mongoTemplate

mappingMongoConverter

protected org.springframework.data.mongodb.core.convert.MappingMongoConverter mappingMongoConverter

applicationContext

protected org.springframework.context.ApplicationContext applicationContext

messageBuilderFactory

protected MessageBuilderFactory messageBuilderFactory

Constructor Detail

AbstractConfigurableMongoDbMessageStore

public AbstractConfigurableMongoDbMessageStore(org.springframework.data.mongodb.core.MongoTemplate mongoTemplate,
                                               java.lang.String collectionName)

AbstractConfigurableMongoDbMessageStore

public AbstractConfigurableMongoDbMessageStore(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory,
                                               java.lang.String collectionName)

AbstractConfigurableMongoDbMessageStore

public AbstractConfigurableMongoDbMessageStore(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory,
                                               org.springframework.data.mongodb.core.convert.MappingMongoConverter mappingMongoConverter,
                                               java.lang.String collectionName)

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

getMessage

public org.springframework.messaging.Message<?> getMessage(java.util.UUID id)

removeMessageGroup

public void removeMessageGroup(java.lang.Object groupId)

Description copied from interface: BasicMessageGroupStore

Remove the message group with this id.

Specified by:

removeMessageGroup in interface BasicMessageGroupStore

Parameters:

groupId - The id of the group to remove.

messageGroupSize

public int messageGroupSize(java.lang.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.

getNextId

protected int getNextId()

Perform MongoDB INC operation for the document, which contains the MessageDocument sequence, and return the new incremented value for the new MessageDocument. The SEQUENCE_NAME document is created on demand.

Returns:

the next sequence value.

addMessageDocument

protected void addMessageDocument(MessageDocument document)

groupIdQuery

protected static org.springframework.data.mongodb.core.query.Query groupIdQuery(java.lang.Object groupId)