Spring Integration

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>, org.springframework.beans.factory.InitializingBean, MessageGroupStore, MessageStore

public class GemfireMessageStore
extends AbstractKeyValueMessageStore
implements org.springframework.beans.factory.InitializingBean

Gemfire implementation of the key/value style MessageStore and MessageGroupStore

Since:
2.1
Author:
Mark Fisher, Oleg Zhurakousky, David Turanski

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
GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
          Provides a cache reference used to create a message store region named 'messageStoreRegion'
GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)
          Provides the region to be used for the message store.
 
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, 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

GemfireMessageStore

public GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)
Provides the region to be used for the message store. This is useful when using a configured region. This is also required if using a client region on a remote cache server.

Parameters:
messageStoreRegion - the region

GemfireMessageStore

public GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
Provides a cache reference used to create a message store region named 'messageStoreRegion'

Parameters:
cache -
Method Detail

setIgnoreJta

public void setIgnoreJta(boolean ignoreJta)

afterPropertiesSet

public void afterPropertiesSet()
Specified by:
afterPropertiesSet in interface org.springframework.beans.factory.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

Spring Integration