org.springframework.integration.redis.store
Class RedisMessageStore
java.lang.Object
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.AbstractKeyValueMessageStore
org.springframework.integration.redis.store.RedisMessageStore
- All Implemented Interfaces:
- java.lang.Iterable<org.springframework.integration.store.MessageGroup>, org.springframework.integration.store.MessageGroupStore, org.springframework.integration.store.MessageStore
public class RedisMessageStore
- extends org.springframework.integration.store.AbstractKeyValueMessageStore
Redis implementation of the key/value style MessageStore and MessageGroupStore
- Since:
- 2.1
| Fields inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore |
CREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX |
| Fields inherited from class org.springframework.integration.store.AbstractMessageGroupStore |
logger |
|
Constructor Summary |
RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
|
|
Method Summary |
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)
|
| Methods inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore |
addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroup |
| Methods inherited from class org.springframework.integration.store.AbstractMessageGroupStore |
expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setExpiryCallbacks, setTimeoutOnIdle |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RedisMessageStore
public RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
setValueSerializer
public void setValueSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> valueSerializer)
doRetrieve
protected java.lang.Object doRetrieve(java.lang.Object id)
- Specified by:
doRetrieve in class org.springframework.integration.store.AbstractKeyValueMessageStore
doStore
protected void doStore(java.lang.Object id,
java.lang.Object objectToStore)
- Specified by:
doStore in class org.springframework.integration.store.AbstractKeyValueMessageStore
doRemove
protected java.lang.Object doRemove(java.lang.Object id)
- Specified by:
doRemove in class org.springframework.integration.store.AbstractKeyValueMessageStore
doListKeys
protected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
- Specified by:
doListKeys in class org.springframework.integration.store.AbstractKeyValueMessageStore