org.springframework.integration.gemfire.store
Class GemfireMessageStore
java.lang.Object
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.AbstractKeyValueMessageStore
org.springframework.integration.gemfire.store.GemfireMessageStore
- All Implemented Interfaces:
- java.lang.Iterable<org.springframework.integration.store.MessageGroup>, org.springframework.beans.factory.InitializingBean, org.springframework.integration.store.MessageGroupStore, org.springframework.integration.store.MessageStore
public class GemfireMessageStore
- extends org.springframework.integration.store.AbstractKeyValueMessageStore
- implements org.springframework.beans.factory.InitializingBean
Gemfire 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 |
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 |
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 -
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 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