public class RedisMessageStore
extends org.springframework.integration.store.AbstractKeyValueMessageStore
implements org.springframework.beans.factory.BeanClassLoaderAware
MessageStore and MessageGroupStore| Constructor and Description |
|---|
RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
Construct
RedisMessageStore based on the provided
RedisConnectionFactory and default empty prefix. |
RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
java.lang.String prefix)
Construct
RedisMessageStore based on the provided
RedisConnectionFactory and prefix. |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.Collection<?> |
doListKeys(java.lang.String keyPattern) |
protected java.lang.Object |
doRemove(java.lang.Object id) |
protected void |
doRemoveAll(java.util.Collection<java.lang.Object> ids) |
protected java.lang.Object |
doRetrieve(java.lang.Object id) |
protected void |
doStore(java.lang.Object id,
java.lang.Object objectToStore) |
protected void |
doStoreIfAbsent(java.lang.Object id,
java.lang.Object objectToStore) |
void |
setBeanClassLoader(java.lang.ClassLoader classLoader) |
void |
setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer) |
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizepublic RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
RedisMessageStore based on the provided
RedisConnectionFactory and default empty prefix.connectionFactory - the RedisConnectionFactory to usepublic RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
java.lang.String prefix)
RedisMessageStore based on the provided
RedisConnectionFactory and prefix.connectionFactory - the RedisConnectionFactory to useprefix - the key prefix to use, allowing the same broker to be used for
multiple stores.AbstractKeyValueMessageStore.AbstractKeyValueMessageStore(String)public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAwarepublic void setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer)
protected java.lang.Object doRetrieve(java.lang.Object id)
doRetrieve in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected void doStore(java.lang.Object id,
java.lang.Object objectToStore)
doStore in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected void doStoreIfAbsent(java.lang.Object id,
java.lang.Object objectToStore)
doStoreIfAbsent in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected java.lang.Object doRemove(java.lang.Object id)
doRemove in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected void doRemoveAll(java.util.Collection<java.lang.Object> ids)
doRemoveAll in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys in class org.springframework.integration.store.AbstractKeyValueMessageStore