public class GemfireMessageStore extends AbstractKeyValueMessageStore implements InitializingBean
MessageStore and
MessageGroupStoreMessageGroupStore.MessageGroupCallbackCREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXlogger| 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<Object,Object> messageStoreRegion)
Provides the region to be used for the message store.
|
GemfireMessageStore(com.gemstone.gemfire.cache.Region<Object,Object> messageStoreRegion,
String prefix)
Construct a
GemfireMessageStore instance based on the provided |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet()
Deprecated.
|
protected Collection<?> |
doListKeys(String keyPattern) |
protected Object |
doRemove(Object id) |
protected Object |
doRetrieve(Object id) |
protected void |
doStore(Object id,
Object objectToStore) |
void |
setIgnoreJta(boolean ignoreJta)
Deprecated.
with no-op, in favor of externally configured region.
|
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageGroup, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroup, removeMessageGroup, removeMessagesFromGroup, setLastReleasedSequenceNumberForGroupaddMessageToGroup, copy, expireMessageGroups, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setBeanFactory, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdlegetRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitforEach, spliteratorpublic GemfireMessageStore(com.gemstone.gemfire.cache.Region<Object,Object> messageStoreRegion)
messageStoreRegion - The region.public GemfireMessageStore(com.gemstone.gemfire.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.@Deprecated public GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
cache - The cache.@Deprecated public void setIgnoreJta(boolean ignoreJta)
ignoreJta - boolean flag to ignore JTA on the Gemfire Region.@Deprecated public void afterPropertiesSet()
afterPropertiesSet in interface InitializingBeanprotected Object doRetrieve(Object id)
doRetrieve in class AbstractKeyValueMessageStoreprotected void doStore(Object id, Object objectToStore)
doStore in class AbstractKeyValueMessageStoreprotected Object doRemove(Object id)
doRemove in class AbstractKeyValueMessageStoreprotected Collection<?> doListKeys(String keyPattern)
doListKeys in class AbstractKeyValueMessageStore