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)
Deprecated.
- use the other constructor and provide a region directly.
|
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, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupcopy, expireMessageGroups, getGroupMetadata, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getOneMessageFromGroup, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setBeanFactory, setExpiryCallbacks, setTimeoutOnIdlegetRemoveBatchSize, setRemoveBatchSizepublic GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)
messageStoreRegion - The region.@Deprecated 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.InitializingBeanprotected java.lang.Object doRetrieve(java.lang.Object id)
doRetrieve in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected void doStore(java.lang.Object id,
java.lang.Object objectToStore)
doStore in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected java.lang.Object doRemove(java.lang.Object id)
doRemove in class org.springframework.integration.store.AbstractKeyValueMessageStoreprotected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys in class org.springframework.integration.store.AbstractKeyValueMessageStore