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) |
| 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 java.lang.Object |
doRetrieve(java.lang.Object id) |
protected void |
doStore(java.lang.Object id,
java.lang.Object objectToStore) |
void |
setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer) |
addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroupexpireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setExpiryCallbacks, setTimeoutOnIdlepublic RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public 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 java.lang.Object doRemove(java.lang.Object id)
doRemove in class AbstractKeyValueMessageStoreprotected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys in class AbstractKeyValueMessageStore