public class GemfireMessageStore extends AbstractKeyValueMessageStore
MessageStore および MessageGroupStore の Gemfire 実装 MessageGroupStore.MessageGroupCallbackMESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXlogger| コンストラクターと説明 |
|---|
GemfireMessageStore(org.apache.geode.cache.Region<ObjectSE, ObjectSE> messageStoreRegion) メッセージストアに使用される領域を提供します。 |
GemfireMessageStore(org.apache.geode.cache.Region<ObjectSE, ObjectSE> messageStoreRegion, StringSE prefix) 提供されたものに基づいて GemfireMessageStore インスタンスを構築します |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected CollectionSE<?> | doListKeys(StringSE keyPattern) |
protected ObjectSE | doRemove(ObjectSE id) |
protected void | doRemoveAll(CollectionSE<ObjectSE> ids) |
protected ObjectSE | doRetrieve(ObjectSE id) |
protected void | doStore(ObjectSE id, ObjectSE objectToStore) |
protected void | doStoreIfAbsent(ObjectSE id, ObjectSE 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, setRemoveBatchSizecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEforEachSE, spliteratorSEpublic GemfireMessageStore(org.apache.geode.cache.Region<ObjectSE,ObjectSE> messageStoreRegion)
messageStoreRegion - 領域。public GemfireMessageStore(org.apache.geode.cache.Region<ObjectSE,ObjectSE> messageStoreRegion, StringSE prefix)
GemfireMessageStore インスタンスを構築します messageStoreRegion - 使用する領域。prefix - 使用するキープレフィックス。同じリージョンを複数のストアで使用できます。protected ObjectSE doRetrieve(ObjectSE id)
AbstractKeyValueMessageStore の doRetrieve protected void doStore(ObjectSE id, ObjectSE objectToStore)
AbstractKeyValueMessageStore の doStore protected void doStoreIfAbsent(ObjectSE id, ObjectSE objectToStore)
AbstractKeyValueMessageStore の doStoreIfAbsent protected ObjectSE doRemove(ObjectSE id)
AbstractKeyValueMessageStore の doRemove protected void doRemoveAll(CollectionSE<ObjectSE> ids)
AbstractKeyValueMessageStore の doRemoveAll protected CollectionSE<?> doListKeys(StringSE keyPattern)
AbstractKeyValueMessageStore の doListKeys