クラス MongoDbMessageSource
java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<ObjectSE>
org.springframework.integration.mongodb.inbound.AbstractMongoDbMessageSource<ObjectSE>
org.springframework.integration.mongodb.inbound.MongoDbMessageSource
- 実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, MessageSource<ObjectSE>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement
Query の実行結果であるペイロードを持つ Message を返す MessageSource のインスタンス。expectSingleResult が false (デフォルト) の場合、MongoDb Query は ListSE を返す MongoOperations.find(Query, Class) メソッドを使用して実行されます。返された ListSE は、{ AbstractMessageSource.receive() メソッドによって返される Message のペイロードとして使用されます。空の ListSE は null として扱われるため、{ AbstractMessageSource.receive() メソッドによって返される Message はなくなります。expectSingleResult が true の場合、代わりに MongoOperations.findOne(Query, Class) が使用され、メッセージペイロードはクエリから返される単一のオブジェクトになります。
- 導入:
- 2.2
- 作成者:
- Amol Nayak, Oleg Zhurakousky, Yaron Yamin, Artem Bilan, Gary Russell
ネストされたクラスの概要
インターフェース IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス AbstractMongoDbMessageSource から継承されたフィールド
queryExpressionクラス AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEコンストラクター概要
コンストラクターコンストラクター説明MongoDbMessageSource(MongoOperations mongoTemplate, Expression queryExpression) 提供されたMongoOperationsと SpEL 式を使用してインスタンスを作成します。これは Mongo の「クエリ」文字列に解決される必要があります。MongoDbMessageSource(MongoDatabaseFactory mongoDbFactory, Expression queryExpression) 提供されたMongoDatabaseFactoryと 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
コンストラクターの詳細
MongoDbMessageSource
指定されたMongoDatabaseFactoryと SpEL 式を使用して、MongoDb の「クエリ」文字列に解決されるインスタンスを作成します。"queryExpression" は、AbstractMessageSource.receive()メソッドが呼び出されるたびに評価されます。- パラメーター:
mongoDbFactory- mongodb ファクトリ。queryExpression- クエリ式。
MongoDbMessageSource
指定されたMongoOperationsと SpEL 式を使用してインスタンスを作成します。このインスタンスは Mongo の「クエリ」文字列に解決されます。MongoOperationsは完全に初期化され、使用可能な状態であると想定しています。"queryExpression" は、AbstractMessageSource.receive()メソッドが呼び出されるたびに評価されます。- パラメーター:
mongoTemplate- mongo テンプレート。queryExpression- クエリ式。
方法の詳細
getComponentType
onInit
protected void onInit()- オーバーライド:
- クラス
AbstractMongoDbMessageSource<ObjectSE>のonInit
doReceive
Queryを実行し、その結果をメッセージペイロードとして返します。ペイロードは、AbstractMongoDbMessageSource.getEntityClass()で識別された型のオブジェクトの要素をListSE とするか、AbstractMongoDbMessageSource.isExpectSingleResult()属性の値（デフォルトは 'false' ）に基づいてAbstractMongoDbMessageSource.getEntityClass()で識別された型の単一の要素をMessageとし、ListSE 型のペイロードを返すかのいずれかです。クエリで使用されるコレクション名は、MongoHeaders.COLLECTION_NAMEヘッダーで指定されます。- 次で指定:
- クラス
AbstractMessageSource<ObjectSE>のdoReceive - 戻り値:
- 返された値。