public class GemfireMessageStore extends AbstractKeyValueMessageStore implements 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<Object,Object> messageStoreRegion)
Provides the region to be used for the message store.
|
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
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) |
addMessage, addMessagesToGroup, completeGroup, doAddMessage, getGroupMetadata, getMessage, getMessageCount, getMessageGroup, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public GemfireMessageStore(com.gemstone.gemfire.cache.Region<Object,Object> messageStoreRegion)
messageStoreRegion
- The region.@Deprecated public GemfireMessageStore(com.gemstone.gemfire.cache.Cache cache)
cache
- The cache.public void setIgnoreJta(boolean ignoreJta)
public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
protected Object doRetrieve(Object id)
doRetrieve
in class AbstractKeyValueMessageStore
protected void doStore(Object id, Object objectToStore)
doStore
in class AbstractKeyValueMessageStore
protected Object doRemove(Object id)
doRemove
in class AbstractKeyValueMessageStore
protected Collection<?> doListKeys(String keyPattern)
doListKeys
in class AbstractKeyValueMessageStore