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