Class GemfireMessageStore
java.lang.Object
org.springframework.integration.store.AbstractBatchingMessageGroupStore
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.integration.store.BasicMessageGroupStore,org.springframework.integration.store.MessageGroupStore,org.springframework.integration.store.MessageStore
public class GemfireMessageStore
extends org.springframework.integration.store.AbstractKeyValueMessageStore
Gemfire implementation of the key/value style
MessageStore and
MessageGroupStore- Since:
- 2.1
-
Nested Class Summary
-
Field Summary
-
Constructor Summary
Constructors Constructor Description GemfireMessageStore(org.apache.geode.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)Provides the region to be used for the message store.GemfireMessageStore(org.apache.geode.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion, java.lang.String prefix)Construct aGemfireMessageStoreinstance based on the provided -
Method Summary
Modifier and Type Method Description protected java.util.Collection<?>doListKeys(java.lang.String keyPattern)protected java.lang.ObjectdoRemove(java.lang.Object id)protected voiddoRemoveAll(java.util.Collection<java.lang.Object> ids)protected java.lang.ObjectdoRetrieve(java.lang.Object id)protected voiddoStore(java.lang.Object id, java.lang.Object objectToStore)protected voiddoStoreIfAbsent(java.lang.Object id, java.lang.Object objectToStore)Methods inherited from class org.springframework.integration.store.AbstractKeyValueMessageStore
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroup, streamMessagesForGroupMethods inherited from class org.springframework.integration.store.AbstractMessageGroupStore
addMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdleMethods inherited from class org.springframework.integration.store.AbstractBatchingMessageGroupStore
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
-
Constructor Details
-
GemfireMessageStore
public GemfireMessageStore(org.apache.geode.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(org.apache.geode.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion, java.lang.String prefix)Construct aGemfireMessageStoreinstance based on the provided- Parameters:
messageStoreRegion- the region to use.prefix- the key prefix to use, allowing the same region to be used for multiple stores.- Since:
- 4.3.12
-
-
Method Details
-
doRetrieve
protected java.lang.Object doRetrieve(java.lang.Object id)- Specified by:
doRetrievein classorg.springframework.integration.store.AbstractKeyValueMessageStore
-
doStore
protected void doStore(java.lang.Object id, java.lang.Object objectToStore)- Specified by:
doStorein classorg.springframework.integration.store.AbstractKeyValueMessageStore
-
doStoreIfAbsent
protected void doStoreIfAbsent(java.lang.Object id, java.lang.Object objectToStore)- Specified by:
doStoreIfAbsentin classorg.springframework.integration.store.AbstractKeyValueMessageStore
-
doRemove
protected java.lang.Object doRemove(java.lang.Object id)- Specified by:
doRemovein classorg.springframework.integration.store.AbstractKeyValueMessageStore
-
doRemoveAll
protected void doRemoveAll(java.util.Collection<java.lang.Object> ids)- Specified by:
doRemoveAllin classorg.springframework.integration.store.AbstractKeyValueMessageStore
-
doListKeys
protected java.util.Collection<?> doListKeys(java.lang.String keyPattern)- Specified by:
doListKeysin classorg.springframework.integration.store.AbstractKeyValueMessageStore
-