クラス ReactiveMongoDbStoringMessageHandler
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractReactiveMessageHandler
org.springframework.integration.mongodb.outbound.ReactiveMongoDbStoringMessageHandler
- 実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, ReactiveMessageHandler
リアクティブ MongoDb サポートを使用して、メッセージペイロードを MongoDb コレクションに書き込む
ReactiveMessageHandler の実装、コレクションは collectionNameExpression の評価によって識別されます。- 導入:
- 5.3
- 作成者:
- David Turanski, Artem Bilan
ネストされたクラスの概要
インターフェース IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEインターフェース Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCEコンストラクター概要
コンストラクターコンストラクター説明ReactiveMongoDbStoringMessageHandler(ReactiveMongoOperations mongoTemplate) 提供されたReactiveMongoOperationsの完全に作成および初期化されたインスタンスを使用して、このインスタンスを構築します。ReactiveMongoDbStoringMessageHandler(ReactiveMongoDatabaseFactory mongoDbFactory) 提供されたReactiveMongoDatabaseFactoryを使用してこのインスタンスを構築します。方法の概要
修飾子と型メソッド説明protected reactor.core.publisher.Mono<VoidSE> handleMessageInternal(Message<?> message) protected voidonInit()サブクラスは、初期化ロジック用にこれを実装できます。voidsetCollectionNameExpression(Expression collectionNameExpression) ReactiveMongoOperationsがデータを格納するために使用するコレクション名に解決される SpELExpressionを設定しますvoidsetMongoConverter(MongoConverter mongoConverter) MongoDb に書き込まれたデータの直列化を支援するために使用されるカスタムMongoConverterを提供します。クラス AbstractReactiveMessageHandler から継承されたメソッド
handleMessageクラス MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackクラス IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース IntegrationManagement から継承されたメソッド
getThisAsインターフェース NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
ReactiveMongoDbStoringMessageHandler
提供されたReactiveMongoDatabaseFactoryを使用してこのインスタンスを構築します。- パラメーター:
mongoDbFactory- リアクティブ型 mongoDatabase ファクトリ。
ReactiveMongoDbStoringMessageHandler
提供されたReactiveMongoOperationsの完全に作成および初期化されたインスタンスを使用して、このインスタンスを構築します。- パラメーター:
mongoTemplate- ReactiveMongoOperations 実装。
方法の詳細
setMongoConverter
MongoDb に書き込まれたデータの直列化を支援するために使用されるカスタムMongoConverterを提供します。このインスタンスがReactiveMongoDatabaseFactoryで構築された場合にのみ許可されます。- パラメーター:
mongoConverter- mongo コンバーター。
setCollectionNameExpression
ReactiveMongoOperationsがデータを格納するために使用するコレクション名に解決される SpELExpressionを設定します- パラメーター:
collectionNameExpression- コレクション名の式。
getComponentType
- 次で指定:
- インターフェース
NamedComponent内のgetComponentType - オーバーライド:
- クラス
MessageHandlerSupportのgetComponentType
onInit
protected void onInit()クラスからコピーされた説明:IntegrationObjectSupportサブクラスは、初期化ロジック用にこれを実装できます。- オーバーライド:
- クラス
IntegrationObjectSupportのonInit
handleMessageInternal
- 次で指定:
- クラス
AbstractReactiveMessageHandlerのhandleMessageInternal