public class RedisMessageStore extends AbstractKeyValueMessageStore
MessageStore
and MessageGroupStore
MessageGroupStore.MessageGroupCallback
CREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
logger
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) |
void |
setValueSerializer(RedisSerializer<?> valueSerializer) |
addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroup
copy, expireMessageGroups, getGroupMetadata, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getOneMessageFromGroup, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setBeanFactory, setExpiryCallbacks, setTimeoutOnIdle
getRemoveBatchSize, setRemoveBatchSize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public RedisMessageStore(RedisConnectionFactory connectionFactory)
public void setValueSerializer(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