クラス 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
ネストされたクラスの概要
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス org.springframework.integration.mongodb.inbound.AbstractMongoDbMessageSource から継承されたフィールド
queryExpressionクラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース org.springframework.integration.support.management.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 の「クエリ」文字列に解決される必要があります。方法の概要
クラス org.springframework.integration.mongodb.inbound.AbstractMongoDbMessageSource から継承されたメソッド
evaluateCollectionNameExpression, evaluateQueryExpression, evaluateUpdateExpression, getApplicationContext, getByIdInQuery, getCollectionNameExpression, getEntityClass, getMongoConverter, getUpdateExpression, idForEntity, isExpectSingleResult, isInitialized, setApplicationContext, setCollectionNameExpression, setEntityClass, setExpectSingleResult, setInitialized, setMongoConverter, setUpdateExpressionクラス org.springframework.integration.endpoint.AbstractMessageSource から継承されたメソッド
buildMessage, destroy, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeクラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたメソッド
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService, setSimpleEvaluationContextクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs, isObserved, registerObservationRegistryインターフェース org.springframework.integration.core.MessageSource から継承されたメソッド
getIntegrationPatternTypeインターフェース org.springframework.integration.support.context.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 - 戻り値:
- 返された値。