クラス HazelcastMessageStore
java.lang.ObjectSE
org.springframework.integration.store.AbstractBatchingMessageGroupStore
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.store.AbstractKeyValueMessageStore
org.springframework.integration.hazelcast.store.HazelcastMessageStore
- 実装されているすべてのインターフェース:
IterableSE<MessageGroup>
、BasicMessageGroupStore
、MessageGroupStore
、MessageStore
Hazelcast
IMap
ベースの AbstractKeyValueMessageStore
実装。- 作成者:
- Vinicius Carvalho, Artem Bilan
ネストされたクラスの要約
インターフェース org.springframework.integration.store.MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallback
フィールドのサマリー
クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたフィールド
MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIX
クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたフィールド
GROUP_ID_MUST_NOT_BE_NULL, INTERRUPTED_WHILE_OBTAINING_LOCK, logger
コンストラクターの概要
コンストラクターコンストラクター説明HazelcastMessageStore
(com.hazelcast.core.HazelcastInstance hazelcastInstance) HazelcastMessageStore
(com.hazelcast.map.IMap<ObjectSE, ObjectSE> map) メソッドのサマリー
修飾子と型メソッド説明protected CollectionSE
<?> doListKeys
(StringSE keyPattern) protected ObjectSE
protected void
doRemoveAll
(CollectionSE<ObjectSE> ids) protected ObjectSE
doRetrieve
(ObjectSE id) protected void
protected void
doStoreIfAbsent
(ObjectSE id, ObjectSE objectToStore) クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたメソッド
addMessage, doAddMessage, doAddMessage, doAddMessagesToGroup, doCompleteGroup, doPollMessageFromGroup, doRemoveMessageFromGroupById, doRemoveMessageGroup, doRemoveMessagesFromGroup, doSetGroupCondition, doSetLastReleasedSequenceNumberForGroup, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageFromGroup, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, removeMessage, streamMessagesForGroup
クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド
addMessagesToGroup, addMessageToGroup, completeGroup, copy, executeLocked, executeLocked, expireMessageGroups, getLockRegistry, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, pollMessageFromGroup, registerMessageGroupExpiryCallback, removeMessageFromGroupById, removeMessageGroup, removeMessagesFromGroup, removeMessagesFromGroup, setExpiryCallbacks, setGroupCondition, setLastReleasedSequenceNumberForGroup, setLazyLoadMessageGroups, setLockRegistry, setTimeoutOnIdle
クラス org.springframework.integration.store.AbstractBatchingMessageGroupStore から継承されたメソッド
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSize
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース java.lang.IterableSE から継承されたメソッド
forEachSE, spliterator
コンストラクターの詳細
HazelcastMessageStore
public HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance) HazelcastMessageStore
メソッドの詳細
doRetrieve
- 次で指定:
- クラス
AbstractKeyValueMessageStore
のdoRetrieve
doStore
- 次で指定:
- クラス
AbstractKeyValueMessageStore
のdoStore
doStoreIfAbsent
- 次で指定:
- クラス
AbstractKeyValueMessageStore
のdoStoreIfAbsent
doRemoveAll
- 次で指定:
- クラス
AbstractKeyValueMessageStore
のdoRemoveAll
doRemove
- 次で指定:
- クラス
AbstractKeyValueMessageStore
のdoRemove
doListKeys
- 次で指定:
- クラス
AbstractKeyValueMessageStore
のdoListKeys