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