public class RedisMessageStore extends AbstractKeyValueMessageStore
MessageStore and MessageGroupStoreMessageGroupStore.MessageGroupCallbackCREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXlogger| Constructor and Description |
|---|
RedisMessageStore(RedisConnectionFactory connectionFactory) |
| 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) |
protected void |
doStoreIfAbsent(Object id,
Object objectToStore) |
void |
setValueSerializer(RedisSerializer<?> valueSerializer) |
addMessage, addMessagesToGroup, completeGroup, getGroupMetadata, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorpublic RedisMessageStore(RedisConnectionFactory connectionFactory)
public void setValueSerializer(RedisSerializer<?> valueSerializer)
protected Object doRetrieve(Object id)
doRetrieve in class AbstractKeyValueMessageStoreprotected void doStore(Object id, Object objectToStore)
doStore in class AbstractKeyValueMessageStoreprotected void doStoreIfAbsent(Object id, Object objectToStore)
doStoreIfAbsent in class AbstractKeyValueMessageStoreprotected Object doRemove(Object id)
doRemove in class AbstractKeyValueMessageStoreprotected Collection<?> doListKeys(String keyPattern)
doListKeys in class AbstractKeyValueMessageStore