Class MongoDbChannelMessageStore

All Implemented Interfaces:
Iterable<MessageGroup>, Aware, InitializingBean, ApplicationContextAware, BasicMessageGroupStore, ChannelMessageStore, MessageGroupStore, PriorityCapableChannelMessageStore

public class MongoDbChannelMessageStore
extends AbstractConfigurableMongoDbMessageStore
implements PriorityCapableChannelMessageStore
MongoDB PriorityCapableChannelMessageStore implementation. This message store shall be used for message channels only.

Provide the priorityEnabled option to allow to poll messages via priority manner.

As a priority document field the IntegrationMessageHeaderAccessor.PRIORITY message header is used.

The same collection can be used for and, but the different instances of MongoDbChannelMessageStore should be used for those cases, and the last one with priorityEnabled = true option.

Artem Bilan