クラス MongoDbChannelMessageStore
java.lang.ObjectSE
org.springframework.integration.store.AbstractBatchingMessageGroupStore
org.springframework.integration.store.AbstractMessageGroupStore
org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore
org.springframework.integration.mongodb.store.MongoDbChannelMessageStore
- 実装済みのインターフェース一覧:
IterableSE<MessageGroup>, Aware, InitializingBean, ApplicationContextAware, BasicMessageGroupStore, ChannelMessageStore, MessageGroupStore, PriorityCapableChannelMessageStore
public class MongoDbChannelMessageStore
extends AbstractConfigurableMongoDbMessageStore
implements PriorityCapableChannelMessageStore
MongoDB
PriorityCapableChannelMessageStore の実装。このメッセージストアは、メッセージチャネルにのみ使用されます。priorityEnabled オプションを提供して、priority 方式でメッセージをポーリングできるようにします。
優先ドキュメントフィールドとして、IntegrationMessageHeaderAccessor.PRIORITY メッセージヘッダーが使用されます。
同じコレクションを org.springframework.integration.channel.QueueChannel と org.springframework.integration.channel.PriorityChannel に使用できますが、これらの場合には MongoDbChannelMessageStore の異なるインスタンスを使用し、最後のインスタンスは priorityEnabled = true オプションを使用する必要があります。
- 導入:
- 4.0
- 作成者:
- Artem Bilan, Adama Sorho, Youbin Wu
ネストされたクラスの概要
インターフェース MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallbackフィールド概要
フィールドクラス AbstractConfigurableMongoDbMessageStore から継承されたフィールド
collectionName, logger, mongoDbFactory, SEQUENCE_NAMEクラス AbstractMessageGroupStore から継承されたフィールド
INTERRUPTED_WHILE_OBTAINING_LOCKコンストラクター概要
コンストラクターコンストラクター説明MongoDbChannelMessageStore(MongoTemplate mongoTemplate) MongoDbChannelMessageStore(MongoTemplate mongoTemplate, StringSE collectionName) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, @Nullable MappingMongoConverter mappingMongoConverter, StringSE collectionName) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter) 方法の概要
修飾子と型メソッド説明addMessageToGroup(ObjectSE groupId, Message<?> message) グループ ID に関連付けてメッセージを保存します。protected voidprotected @Nullable Message<?> doPollMessageFromGroup(ObjectSE groupId) getMessageGroup(ObjectSE groupId) 完全には使用されていません。booleanvoidsetPriorityEnabled(boolean priorityEnabled) クラス AbstractConfigurableMongoDbMessageStore から継承されたメソッド
addMessageDocument, afterPropertiesSet, doAddMessagesToGroup, doCompleteGroup, doRemoveMessageGroup, doRemoveMessagesFromGroup, doSetGroupCondition, doSetLastReleasedSequenceNumberForGroup, getApplicationContext, getMappingMongoConverter, getMessage, getMessageBuilderFactory, getMessageMetadata, getMessagesForGroup, getMongoTemplate, getNextId, groupIdQuery, iterator, messageGroupSize, setApplicationContext, setCreateIndexesクラス AbstractMessageGroupStore から継承されたメソッド
addMessagesToGroup, completeGroup, copy, doRemoveMessageFromGroupById, 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インターフェース BasicMessageGroupStore から継承されたメソッド
messageGroupSize, pollMessageFromGroup, removeMessageGroupインターフェース IterableSE から継承されたメソッド
forEachSE, spliteratorインターフェース MessageGroupStore から継承されたメソッド
getGroupMetadata, getMessageFromGroup, getOneMessageFromGroup, streamMessagesForGroup
フィールドの詳細
DEFAULT_COLLECTION_NAME
コンストラクターの詳細
MongoDbChannelMessageStore
MongoDbChannelMessageStore
MongoDbChannelMessageStore
MongoDbChannelMessageStore
public MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter) MongoDbChannelMessageStore
MongoDbChannelMessageStore
public MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, @Nullable MappingMongoConverter mappingMongoConverter, StringSE collectionName)
方法の詳細
setPriorityEnabled
public void setPriorityEnabled(boolean priorityEnabled) isPriorityEnabled
public boolean isPriorityEnabled()- 次で指定:
- インターフェース
PriorityCapableChannelMessageStore内のisPriorityEnabled - 戻り値:
- このチャネルメッセージストアでメッセージ優先度が有効になっている場合は true。
createIndexes
protected void createIndexes()- オーバーライド:
- クラス
AbstractConfigurableMongoDbMessageStoreのcreateIndexes
addMessageToGroup
インターフェースからコピーされた説明:BasicMessageGroupStoreグループ ID に関連付けてメッセージを保存します。これは、メッセージをグループ化するために使用できます。- 次で指定:
- インターフェース
BasicMessageGroupStore内のaddMessageToGroup - オーバーライド:
- クラス
AbstractMessageGroupStoreのaddMessageToGroup - パラメーター:
groupId- メッセージを保存するグループ ID。message- メッセージ。- 戻り値:
- メッセージグループ。
getMessageGroup
完全には使用されていません。指定されたグループ ID のみをラップします。- 次で指定:
- インターフェース
BasicMessageGroupStore内のgetMessageGroup - パラメーター:
groupId- グループ識別子。- 戻り値:
- メッセージのグループ。このキーにメッセージが存在しない場合は空です。
doPollMessageFromGroup
- 次で指定:
- クラス
AbstractMessageGroupStoreのdoPollMessageFromGroup