クラス ReactiveMongoDbMessageSource
java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<org.reactivestreams.Publisher<?>>
org.springframework.integration.mongodb.inbound.AbstractMongoDbMessageSource<org.reactivestreams.Publisher<?>>
org.springframework.integration.mongodb.inbound.ReactiveMongoDbMessageSource
- 実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, MessageSource<org.reactivestreams.Publisher<?>>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement
public class ReactiveMongoDbMessageSource
extends AbstractMongoDbMessageSource<org.reactivestreams.Publisher<?>>
Query の実行の結果であるペイロードを含む Message を返す MessageSource のインスタンス。expectSingleResult が false（デフォルト）の場合、MongoDb Query は、Flux を返す ReactiveMongoOperations.find(Query, Class) メソッドを使用して実行されます。返された Flux は、AbstractMessageSource.receive() メソッドによって返される Message のペイロードとして使用されます。expectSingleResult が true の場合、代わりに ReactiveMongoOperations.findOne(Query, Class) が使用され、メッセージペイロードはクエリから返された単一オブジェクトの Mono になります。
- 導入:
- 5.3
- 作成者:
- David Turanski, Artem Bilan
ネストされたクラスの概要
インターフェース IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス AbstractMongoDbMessageSource から継承されたフィールド
queryExpressionクラス AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEコンストラクター概要
コンストラクターコンストラクター説明ReactiveMongoDbMessageSource(ReactiveMongoOperations reactiveMongoTemplate, Expression queryExpression) 提供されたReactiveMongoOperationsと SpEL 式を使用してインスタンスを作成します。これは Mongo の「クエリ」文字列に解決される必要があります。ReactiveMongoDbMessageSource(ReactiveMongoDatabaseFactory reactiveMongoDatabaseFactory, Expression queryExpression) 提供されたReactiveMongoDatabaseFactoryと SpEL 式を使用してインスタンスを作成します。これは MongoDb の「クエリ」文字列に解決される必要があります。方法の概要
クラス AbstractMongoDbMessageSource から継承されたメソッド
evaluateCollectionNameExpression, evaluateQueryExpression, evaluateUpdateExpression, getApplicationContext, getByIdInQuery, getCollectionNameExpression, getEntityClass, getMongoConverter, getUpdateExpression, idForEntity, isExpectSingleResult, isInitialized, setApplicationContext, setCollectionNameExpression, setEntityClass, setExpectSingleResult, setInitialized, setMongoConverter, setUpdateExpressionクラス AbstractMessageSource から継承されたメソッド
buildMessage, destroy, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeクラス AbstractExpressionEvaluator から継承されたメソッド
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService, setSimpleEvaluationContextクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース IntegrationManagement から継承されたメソッド
getThisAs, isObserved, registerObservationRegistryインターフェース MessageSource から継承されたメソッド
getIntegrationPatternTypeインターフェース NamedComponent から継承されたメソッド
getBeanName
コンストラクターの詳細
ReactiveMongoDbMessageSource
public ReactiveMongoDbMessageSource(ReactiveMongoDatabaseFactory reactiveMongoDatabaseFactory, Expression queryExpression) 指定されたReactiveMongoDatabaseFactoryと SpEL 式を使用して、MongoDb の「クエリ」文字列に解決されるインスタンスを作成します。"queryExpression" は、AbstractMessageSource.receive()メソッドが呼び出されるたびに評価されます。- パラメーター:
reactiveMongoDatabaseFactory- reactiveMongoDatabaseFactory ファクトリ。queryExpression- クエリ式。
ReactiveMongoDbMessageSource
public ReactiveMongoDbMessageSource(ReactiveMongoOperations reactiveMongoTemplate, Expression queryExpression) 指定されたReactiveMongoOperationsと SpEL 式を使用してインスタンスを作成します。このインスタンスは Mongo の「クエリ」文字列に解決されます。ReactiveMongoOperationsは完全に初期化され、使用可能な状態であると想定しています。"queryExpression" は、AbstractMessageSource.receive()メソッドが呼び出されるたびに評価されます。- パラメーター:
reactiveMongoTemplate- リアクティブ Mongo テンプレート。queryExpression- クエリ式。
方法の詳細
getComponentType
onInit
protected void onInit()- オーバーライド:
- クラス
AbstractMongoDbMessageSource<org.reactivestreams.Publisher<?>>のonInit
doReceive
Queryを実行して、その結果をメッセージペイロードとして返します。ペイロードは、AbstractMongoDbMessageSource.getEntityClass()によって識別される型のオブジェクトのFluxまたはMono、またはAbstractMongoDbMessageSource.isExpectSingleResult()属性の値に基づいてAbstractMongoDbMessageSource.getEntityClass()によって識別される型の単一要素のいずれかです。デフォルトは "false" であり、結果としてMessageは型Fluxのペイロードになります。クエリで使用されるコレクション名は、MongoHeaders.COLLECTION_NAMEヘッダーで提供されます。- 次で指定:
- クラス
AbstractMessageSource<org.reactivestreams.Publisher<?>>のdoReceive - 戻り値:
- 返された値。