Class RedisChannelPriorityMessageStore

java.lang.Object
org.springframework.integration.redis.store.RedisChannelMessageStore
org.springframework.integration.redis.store.RedisChannelPriorityMessageStore
All Implemented Interfaces:
Aware, BeanClassLoaderAware, BeanNameAware, InitializingBean, BasicMessageGroupStore, ChannelMessageStore, PriorityCapableChannelMessageStore

public class RedisChannelPriorityMessageStore extends RedisChannelMessageStore implements PriorityCapableChannelMessageStore
Specialized Redis PriorityCapableChannelMessageStore that uses lists to back a QueueChannel. Messages are removed in priority order (IntegrationMessageHeaderAccessor.PRIORITY). Priorities 0-9 are supported (9 the highest); invalid priority values are treated with the same priority (none) as messages with no priority header (retrieved after any messages that have a priority).

Requires that groupId is a String.

Since:
4.0
Author:
Gary Russell, Artem Bilan