public class RedisMessageStore extends AbstractKeyValueMessageStore
MessageStore
and MessageGroupStore
MessageGroupStore.MessageGroupCallback
CREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
logger
Constructor and Description |
---|
RedisMessageStore(org.springframework.data.redis.connection.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) |
void |
setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer) |
addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroup
expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setExpiryCallbacks, setTimeoutOnIdle
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public void setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer)
protected Object doRetrieve(Object id)
doRetrieve
in class AbstractKeyValueMessageStore
protected void doStore(Object id, Object objectToStore)
doStore
in class AbstractKeyValueMessageStore
protected Object doRemove(Object id)
doRemove
in class AbstractKeyValueMessageStore
protected Collection<?> doListKeys(String keyPattern)
doListKeys
in class AbstractKeyValueMessageStore
Copyright © 2016. All rights reserved.