public class GemfireMessageStore extends AbstractKeyValueMessageStore
MessageStore
and
MessageGroupStore
MessageGroupStore.MessageGroupCallback
CREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
logger
Constructor and 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 a
GemfireMessageStore instance based on the provided |
Modifier and Type | Method and Description |
---|---|
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) |
protected void |
doStoreIfAbsent(java.lang.Object id,
java.lang.Object objectToStore) |
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroup
addMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdle
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
public GemfireMessageStore(org.apache.geode.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)
messageStoreRegion
- The region.public GemfireMessageStore(org.apache.geode.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion, java.lang.String prefix)
GemfireMessageStore
instance based on the providedmessageStoreRegion
- the region to use.prefix
- the key prefix to use, allowing the same region to be used for
multiple stores.protected java.lang.Object doRetrieve(java.lang.Object id)
doRetrieve
in class AbstractKeyValueMessageStore
protected void doStore(java.lang.Object id, java.lang.Object objectToStore)
doStore
in class AbstractKeyValueMessageStore
protected void doStoreIfAbsent(java.lang.Object id, java.lang.Object objectToStore)
doStoreIfAbsent
in class AbstractKeyValueMessageStore
protected java.lang.Object doRemove(java.lang.Object id)
doRemove
in class AbstractKeyValueMessageStore
protected java.util.Collection<?> doListKeys(java.lang.String keyPattern)
doListKeys
in class AbstractKeyValueMessageStore