public class GemfireMessageStore extends AbstractKeyValueMessageStore implements org.springframework.beans.factory.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 org.springframework.beans.factory.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