public class RedisMessageStore extends AbstractKeyValueMessageStore
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,
String prefix)
Construct
RedisMessageStore based on the provided
RedisConnectionFactory and prefix. |
| Modifier and Type | Method and Description |
|---|---|
protected Collection<?> |
doListKeys(String keyPattern) |
protected Object |
doRemove(Object id) |
protected Object |
doRetrieve(Object id) |
protected void |
doStore(Object id,
Object objectToStore) |
void |
setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer) |
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setBeanFactory, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorpublic 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,
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 setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer)
protected Object doRetrieve(Object id)
doRetrieve in class AbstractKeyValueMessageStoreprotected void doStore(Object id, Object objectToStore)
doStore in class AbstractKeyValueMessageStoreprotected Object doRemove(Object id)
doRemove in class AbstractKeyValueMessageStoreprotected Collection<?> doListKeys(String keyPattern)
doListKeys in class AbstractKeyValueMessageStore