org.springframework.integration.gemfire.store
Class GemfireMessageStore

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

public class GemfireMessageStore
extends AbstractKeyValueMessageStore
implements InitializingBean

Gemfire implementation of the key/value style MessageStore and MessageGroupStore

Since:
2.1

Field Summary
 
Fields inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore
MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
 
Fields inherited from class org.springframework.integration.store.AbstractMessageGroupStore
logger
 
Constructor Summary
GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
           
 
Method Summary
 void afterPropertiesSet()
           
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 setIgnoreJta(boolean ignoreJta)
           
 
Methods inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore
addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, markMessageFromGroup, markMessageGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroup
 
Methods inherited from class org.springframework.integration.store.AbstractMessageGroupStore
expireMessageGroups, getMarkedMessageCountForAllMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, registerMessageGroupExpiryCallback, setExpiryCallbacks
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GemfireMessageStore

public GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
Method Detail

setIgnoreJta

public void setIgnoreJta(boolean ignoreJta)

afterPropertiesSet

public void afterPropertiesSet()
Specified by:
afterPropertiesSet in interface InitializingBean

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