クラス AbstractConfigurableMongoDbMessageStore
java.lang.ObjectSE
org.springframework.integration.store.AbstractBatchingMessageGroupStore
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore
- 実装されているすべてのインターフェース:
IterableSE<MessageGroup>、Aware、InitializingBean、ApplicationContextAware、BasicMessageGroupStore、MessageGroupStore
public abstract class AbstractConfigurableMongoDbMessageStore
extends AbstractMessageGroupStore
implements InitializingBean, ApplicationContextAware
このクラスの実装の一般的なオプションの構成を提供するための、抽象的な MongoDB
AbstractMessageGroupStore 実装。- 導入:
- 4.0
- 作成者:
- Artem Bilan, Adama Sorho, Youbin Wu
ネストされたクラスの要約
インターフェース org.springframework.integration.store.MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallbackフィールドのサマリー
フィールド修飾子と型フィールド説明protected final StringSEprotected final Logprotected final MongoDatabaseFactorystatic final StringSEクラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたフィールド
GROUP_ID_MUST_NOT_BE_NULL, INTERRUPTED_WHILE_OBTAINING_LOCKコンストラクターの概要
コンストラクターコンストラクター説明AbstractConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, StringSE collectionName) AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName) AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName) メソッドのサマリー
修飾子と型メソッド説明protected voidaddMessageDocument(MessageDocument document) voidprotected voidprotected voiddoAddMessagesToGroup(ObjectSE groupId, Message<?>... messages) protected voiddoCompleteGroup(ObjectSE groupId) protected voiddoRemoveMessageGroup(ObjectSE groupId) protected voiddoRemoveMessagesFromGroup(ObjectSE key, CollectionSE<Message<?>> messages) protected voiddoSetGroupCondition(ObjectSE groupId, StringSE condition) protected voiddoSetLastReleasedSequenceNumberForGroup(ObjectSE groupId, int sequenceNumber) protected ApplicationContextprotected MappingMongoConverterMessage<?> getMessage(UUIDSE id) protected MessageBuilderFactoryCollectionSE<Message<?>> getMessagesForGroup(ObjectSE groupId) 指定されたグループ ID のメッセージを取得します。protected MongoTemplateprotected longMessage<?> getOneMessageFromGroup(ObjectSE groupId) MessageGroupから 1 つのMessageを返します。protected static QuerygroupIdQuery(ObjectSE groupId) iterator()intmessageGroupSize(ObjectSE groupId) この MessageGroup のサイズを返します。voidsetApplicationContext(ApplicationContext applicationContext) voidsetCreateIndexes(boolean createIndexes) インデックスを自動作成するかどうかのオプションを定義します。クラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド
addMessagesToGroup, addMessageToGroup, completeGroup, copy, doPollMessageFromGroup, doRemoveMessageFromGroupById, executeLocked, executeLocked, expireMessageGroups, getGroupMetadata, 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インターフェース org.springframework.integration.store.BasicMessageGroupStore から継承されたメソッド
getMessageGroupインターフェース java.lang.IterableSE から継承されたメソッド
forEachSE, spliteratorインターフェース org.springframework.integration.store.MessageGroupStore から継承されたメソッド
getMessageFromGroup, streamMessagesForGroup
フィールドの詳細
SEQUENCE_NAME
- 関連事項:
logger
collectionName
mongoDbFactory
コンストラクターの詳細
AbstractConfigurableMongoDbMessageStore
public AbstractConfigurableMongoDbMessageStore(MongoTemplate mongoTemplate, StringSE collectionName) AbstractConfigurableMongoDbMessageStore
public AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName) AbstractConfigurableMongoDbMessageStore
public AbstractConfigurableMongoDbMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName)
メソッドの詳細
setCreateIndexes
public void setCreateIndexes(boolean createIndexes) インデックスを自動作成するかどうかのオプションを定義します。- パラメーター:
createIndexes- ブール値。- 導入:
- 6.0.8.
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAwareのsetApplicationContext - 例外:
BeansException
getMongoTemplate
getMappingMongoConverter
getApplicationContext
getMessageBuilderFactory
afterPropertiesSet
public void afterPropertiesSet()- 次で指定:
- インターフェース
InitializingBeanのafterPropertiesSet
createIndexes
protected void createIndexes()getMessage
getMessageMetadata
doRemoveMessageGroup
- 次で指定:
- クラス
AbstractMessageGroupStoreのdoRemoveMessageGroup
messageGroupSize
インターフェースからコピーされた説明:BasicMessageGroupStoreこの MessageGroup のサイズを返します。- 次で指定:
- インターフェース
BasicMessageGroupStoreのmessageGroupSize - パラメーター:
groupId- グループ識別子。- 戻り値:
- サイズ。
getNextId
protected long getNextId()MessageDocumentsequenceを含むドキュメントに対して MongoDBINC操作を実行し、新しいMessageDocumentの新しい増分値を返します。SEQUENCE_NAMEドキュメントはオンデマンドで作成されます。- 戻り値:
- 次のシーケンス値。
addMessageDocument
groupIdQuery
doRemoveMessagesFromGroup
- 次で指定:
- クラス
AbstractMessageGroupStoreのdoRemoveMessagesFromGroup
doSetGroupCondition
- 次で指定:
- クラス
AbstractMessageGroupStoreのdoSetGroupCondition
doSetLastReleasedSequenceNumberForGroup
iterator
- 次で指定:
- インターフェース
IterableSE<MessageGroup>のiterator - 次で指定:
- インターフェース
MessageGroupStoreのiterator - 戻り値:
- 現在累積されている
MessageGroupの反復子。
doCompleteGroup
- 次で指定:
- クラス
AbstractMessageGroupStoreのdoCompleteGroup
getOneMessageFromGroup
インターフェースからコピーされた説明:MessageGroupStoreMessageGroupから 1 つのMessageを返します。- 次で指定:
- インターフェース
MessageGroupStoreのgetOneMessageFromGroup - パラメーター:
groupId- グループ識別子。- 戻り値:
Message
doAddMessagesToGroup
- 次で指定:
- クラス
AbstractMessageGroupStoreのdoAddMessagesToGroup
getMessagesForGroup
インターフェースからコピーされた説明:MessageGroupStore指定されたグループ ID のメッセージを取得します。- 次で指定:
- インターフェース
MessageGroupStoreのgetMessagesForGroup - パラメーター:
groupId- メッセージを取得するグループ ID。- 戻り値:
- グループのメッセージ。