クラス 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
ネストされたクラスのサマリー
インターフェース org.springframework.integration.store.MessageGroupStore から継承されたネストクラス / インターフェース
MessageGroupStore.MessageGroupCallbackフィールドのサマリー
フィールドクラス org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore から継承されたフィールド
collectionName, logger, mongoDbFactory, SEQUENCE_NAMEクラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたフィールド
GROUP_ID_MUST_NOT_BE_NULL, INTERRUPTED_WHILE_OBTAINING_LOCKコンストラクターの概要
コンストラクターコンストラクター説明MongoDbChannelMessageStore(MongoTemplate mongoTemplate) MongoDbChannelMessageStore(MongoTemplate mongoTemplate, StringSE collectionName) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, StringSE collectionName) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter) MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter, StringSE collectionName) メソッドのサマリー
修飾子と型メソッド説明addMessageToGroup(ObjectSE groupId, Message<?> message) グループ ID に関連付けてメッセージを保存します。protected voidprotected Message<?> doPollMessageFromGroup(ObjectSE groupId) getMessageGroup(ObjectSE groupId) 完全には使用されていません。booleanvoidsetPriorityEnabled(boolean priorityEnabled) クラス org.springframework.integration.mongodb.store.AbstractConfigurableMongoDbMessageStore から継承されたメソッド
addMessageDocument, afterPropertiesSet, doAddMessagesToGroup, doCompleteGroup, doRemoveMessageGroup, doRemoveMessagesFromGroup, doSetGroupCondition, doSetLastReleasedSequenceNumberForGroup, getApplicationContext, getMappingMongoConverter, getMessage, getMessageBuilderFactory, getMessageMetadata, getMessagesForGroup, getMongoTemplate, getNextId, getOneMessageFromGroup, groupIdQuery, iterator, messageGroupSize, setApplicationContext, setCreateIndexesクラス org.springframework.integration.store.AbstractMessageGroupStore から継承されたメソッド
addMessagesToGroup, completeGroup, copy, 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 から継承されたメソッド
messageGroupSize, pollMessageFromGroup, removeMessageGroupインターフェース java.lang.IterableSE から継承されたメソッド
forEachSE, spliteratorインターフェース org.springframework.integration.store.MessageGroupStore から継承されたメソッド
getMessageFromGroup, streamMessagesForGroup
フィールドの詳細
DEFAULT_COLLECTION_NAME
コンストラクターの詳細
MongoDbChannelMessageStore
MongoDbChannelMessageStore
MongoDbChannelMessageStore
MongoDbChannelMessageStore
public MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, MappingMongoConverter mappingMongoConverter) MongoDbChannelMessageStore
MongoDbChannelMessageStore
public MongoDbChannelMessageStore(MongoDatabaseFactory mongoDbFactory, 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