public class GemfireMessageStore extends AbstractKeyValueMessageStore implements org.springframework.beans.factory.InitializingBean
MessageStore
and
MessageGroupStore
MessageGroupStore.MessageGroupCallback
CREATED_DATE, MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
logger
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<java.lang.Object,java.lang.Object> messageStoreRegion)
Provides the region to be used for the message store.
|
GemfireMessageStore(com.gemstone.gemfire.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 |
---|---|
void |
afterPropertiesSet()
Deprecated.
|
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) |
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, setLastReleasedSequenceNumberForGroup
addMessageToGroup, copy, expireMessageGroups, getMessageBuilderFactory, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setBeanFactory, setExpiryCallbacks, setLazyLoadMessageGroups, setTimeoutOnIdle
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
public GemfireMessageStore(com.gemstone.gemfire.cache.Region<java.lang.Object,java.lang.Object> messageStoreRegion)
messageStoreRegion
- The region.public GemfireMessageStore(com.gemstone.gemfire.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.@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.InitializingBean
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 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