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 org.springframework.integration.channel.QueueChannels and org.springframework.integration.channel.PriorityChannels, but the different instances of MongoDbChannelMessageStore should be used for those cases, and the last one with priorityEnabled = true option.

Since:
4.0
Author:
Artem Bilan, Adama Sorho