public class GemfireMessageStore extends AbstractKeyValueMessageStore
MessageStore and
MessageGroupStoreMessageGroupStore.MessageGroupCallbackCREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXlogger| Constructor and Description |
|---|
GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion)
Provides the region to be used for the message store.
|
GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion,
String prefix)
Construct a
GemfireMessageStore instance based on the provided |
| Modifier and Type | Method and Description |
|---|---|
protected Collection<?> |
doListKeys(String keyPattern) |
protected Object |
doRemove(Object id) |
protected void |
doRemoveAll(Collection<Object> ids) |
protected Object |
doRetrieve(Object id) |
protected void |
doStore(Object id,
Object objectToStore) |
protected void |
doStoreIfAbsent(Object id,
Object objectToStore) |
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorpublic GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion)
messageStoreRegion - The region.public GemfireMessageStore(org.apache.geode.cache.Region<Object,Object> messageStoreRegion, 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 Object doRetrieve(Object id)
doRetrieve in class AbstractKeyValueMessageStoreprotected void doStore(Object id, Object objectToStore)
doStore in class AbstractKeyValueMessageStoreprotected void doStoreIfAbsent(Object id, Object objectToStore)
doStoreIfAbsent in class AbstractKeyValueMessageStoreprotected Object doRemove(Object id)
doRemove in class AbstractKeyValueMessageStoreprotected void doRemoveAll(Collection<Object> ids)
doRemoveAll in class AbstractKeyValueMessageStoreprotected Collection<?> doListKeys(String keyPattern)
doListKeys in class AbstractKeyValueMessageStore