Class RedisChannelPriorityMessageStore

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

public class RedisChannelPriorityMessageStore
extends RedisChannelMessageStore
implements org.springframework.integration.store.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