Spring Integration

org.springframework.integration.redis.store
Class RedisMessageStore

java.lang.Object
  extended by org.springframework.integration.store.AbstractMessageGroupStore
      extended by org.springframework.integration.store.AbstractKeyValueMessageStore
          extended by org.springframework.integration.redis.store.RedisMessageStore
All Implemented Interfaces:
java.lang.Iterable<MessageGroup>, MessageGroupStore, MessageStore

public class RedisMessageStore
extends AbstractKeyValueMessageStore

Redis implementation of the key/value style MessageStore and MessageGroupStore

Since:
2.1
Author:
Oleg Zhurakousky

Field Summary
 
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
 

Constructor Detail

RedisMessageStore

public RedisMessageStore(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
Method Detail

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 AbstractKeyValueMessageStore

doStore

protected void doStore(java.lang.Object id,
                       java.lang.Object objectToStore)
Specified by:
doStore in class AbstractKeyValueMessageStore

doRemove

protected java.lang.Object doRemove(java.lang.Object id)
Specified by:
doRemove in class AbstractKeyValueMessageStore

doListKeys

protected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
Specified by:
doListKeys in class AbstractKeyValueMessageStore

Spring Integration