public class RedisMessageStore extends AbstractKeyValueMessageStore implements org.springframework.beans.factory.BeanClassLoaderAware
MessageStore and MessageGroupStoreMessageGroupStore.MessageGroupCallbackCREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXlogger| 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 AbstractKeyValueMessageStoreprotected void doStore(java.lang.Object id,
java.lang.Object objectToStore)
doStore in class AbstractKeyValueMessageStoreprotected void doStoreIfAbsent(java.lang.Object id,
java.lang.Object objectToStore)
doStoreIfAbsent in class AbstractKeyValueMessageStoreprotected java.lang.Object doRemove(java.lang.Object id)
doRemove in class AbstractKeyValueMessageStoreprotected void doRemoveAll(java.util.Collection<java.lang.Object> ids)
doRemoveAll in class AbstractKeyValueMessageStoreprotected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys in class AbstractKeyValueMessageStore