クラス 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>, IntegrationPattern, BasicMessageGroupStore, MessageGroupStore, MessageStore
Hazelcast
IMap ベースの AbstractKeyValueMessageStore 実装。- 作成者:
- Vinicius Carvalho, Artem Bilan
ネストされたクラスの概要
インターフェース MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallbackフィールド概要
クラス AbstractKeyValueMessageStore から継承されたフィールド
MESSAGE_GROUP_KEY_PREFIX, MESSAGE_KEY_PREFIXクラス AbstractMessageGroupStore から継承されたフィールド
INTERRUPTED_WHILE_OBTAINING_LOCK, loggerコンストラクター概要
コンストラクターコンストラクター説明HazelcastMessageStore(com.hazelcast.core.HazelcastInstance hazelcastInstance) HazelcastMessageStore(com.hazelcast.map.IMap<ObjectSE, ObjectSE> map) 方法の概要
修飾子と型メソッド説明protected @Nullable CollectionSE<?> doListKeys(StringSE keyPattern) protected @Nullable ObjectSEprotected voiddoRemoveAll(CollectionSE<ObjectSE> ids) protected @Nullable ObjectSEdoRetrieve(ObjectSE id) protected voidprotected voiddoStoreIfAbsent(ObjectSE id, ObjectSE objectToStore) クラス 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クラス 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クラス AbstractBatchingMessageGroupStore から継承されたメソッド
getRemoveBatchSize, setMessageGroupFactory, setRemoveBatchSizeクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース IterableSE から継承されたメソッド
forEachSE, spliteratorインターフェース MessageStore から継承されたメソッド
getIntegrationPatternType
コンストラクターの詳細
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