クラス 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 から継承されたフィールド
loggerコンストラクターの概要
コンストラクターコンストラクター説明HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance) HazelcastMessageStore(com.hazelcast.map.IMap<ObjectSE, ObjectSE> map) メソッドのサマリー
修飾子と型メソッド説明protected CollectionSE<?> doListKeys(StringSE keyPattern) protected ObjectSEprotected voiddoRemoveAll(CollectionSE<ObjectSE> ids) protected ObjectSEdoRetrieve(ObjectSE id) protected voidprotected voiddoStoreIfAbsent(ObjectSE id, ObjectSE objectToStore) クラス org.springframework.integration.store.AbstractKeyValueMessageStore から継承されたメソッド
addMessage, addMessagesToGroup, completeGroup, doAddMessage, doAddMessage, getGroupMetadata, getGroupPrefix, getMessage, getMessageCount, getMessageFromGroup, getMessageGroup, getMessageMetadata, getMessagePrefix, getMessagesForGroup, getOneMessageFromGroup, iterator, messageGroupSize, pollMessageFromGroup, removeMessage, removeMessageFromGroupById, removeMessageGroup, removeMessagesFromGroup, setGroupCondition, setLastReleasedSequenceNumberForGroup, streamMessagesForGroupクラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド
addMessageToGroup, copy, expireMessageGroups, getMessageCountForAllMessageGroups, getMessageGroupCount, getMessageGroupFactory, isTimeoutOnIdle, registerMessageGroupExpiryCallback, removeMessagesFromGroup, setExpiryCallbacks, setLazyLoadMessageGroups, 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