public class GemfireMessageStore
extends org.springframework.integration.store.AbstractKeyValueMessageStore
implements org.springframework.beans.factory.InitializingBean
MessageStore
and
MessageGroupStore
Constructor and Description |
---|
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.
|
Modifier and Type | Method and Description |
---|---|
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) |
addMessage, addMessageToGroup, completeGroup, getMessage, getMessageCount, getMessageGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, setLastReleasedSequenceNumberForGroup
copy, expireMessageGroups, getGroupMetadata, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getOneMessageFromGroup, isTimeoutOnIdle, registerMessageGroupExpiryCallback, setBeanFactory, setExpiryCallbacks, setTimeoutOnIdle
public GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)
messageStoreRegion
- The region.public GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
cache
- The cache.public void setIgnoreJta(boolean ignoreJta)
public void afterPropertiesSet()
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
protected java.lang.Object doRetrieve(java.lang.Object id)
doRetrieve
in class org.springframework.integration.store.AbstractKeyValueMessageStore
protected void doStore(java.lang.Object id, java.lang.Object objectToStore)
doStore
in class org.springframework.integration.store.AbstractKeyValueMessageStore
protected java.lang.Object doRemove(java.lang.Object id)
doRemove
in class org.springframework.integration.store.AbstractKeyValueMessageStore
protected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys
in class org.springframework.integration.store.AbstractKeyValueMessageStore