クラス 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 ObjectSEprotected voiddoRemoveAll(CollectionSE<ObjectSE> ids) protected ObjectSEdoRetrieve(ObjectSE id) protected voidprotected voiddoStoreIfAbsent(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