クラス AbstractMongoDbMessageSource<T>
java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<T>
org.springframework.integration.mongodb.inbound.AbstractMongoDbMessageSource<T>
- 型パラメーター:
T
- ペイロード型。
- 実装されたすべてのインターフェース:
Aware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、InitializingBean
、ApplicationContextAware
、MessageSource<T>
、IntegrationPattern
、NamedComponent
、IntegrationInboundManagement
、IntegrationManagement
- 既知の直属サブクラス
MongoDbMessageSource
,ReactiveMongoDbMessageSource
public abstract class AbstractMongoDbMessageSource<T>
extends AbstractMessageSource<T>
implements ApplicationContextAware
一般的な MongoDB ソースオプションとサポートメソッドの
AbstractMessageSource
拡張。- 導入:
- 5.5
- 作成者:
- Artem Bilan
ネストされたクラスのサマリー
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドサマリー
フィールドクラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected StringSE
protected Query
protected Update
protected Query
getByIdInQuery
(CollectionSE<?> entities) ClassSE<?>
idForEntity
(ObjectSE entity) boolean
protected boolean
protected void
onInit()
void
setApplicationContext
(ApplicationContext applicationContext) void
setCollectionNameExpression
(Expression collectionNameExpression) Query
で使用されるコレクション名に解決される SpELExpression
を設定します。void
setEntityClass
(ClassSE<?> entityClass) MongoDb テンプレートの検索操作に渡される entityClass の型を設定します。void
setExpectSingleResult
(boolean expectSingleResult) 呼び出す find * メソッドを管理します。protected void
setInitialized
(boolean initialized) void
setMongoConverter
(MongoConverter mongoConverter) MongoDb から読み取られたデータの逆直列化を支援するために使用されるカスタムMongoConverter
を提供します。void
setUpdateExpression
(Expression updateExpression) コレクションからポーリングされたレコードに対して、オプションのupdate
を指定します。クラス org.springframework.integration.endpoint.AbstractMessageSource から継承されたメソッド
buildMessage, destroy, doReceive, getBeanName, 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
クラス 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 から継承されたメソッド
getComponentType
フィールドの詳細
queryExpression
コンストラクターの詳細
AbstractMongoDbMessageSource
メソッドの詳細
setEntityClass
MongoDb テンプレートの検索操作に渡される entityClass の型を設定します。デフォルトはDBObject
です。- パラメーター:
entityClass
- エンティティクラス。
setExpectSingleResult
public void setExpectSingleResult(boolean expectSingleResult) 呼び出す find * メソッドを管理します。デフォルトは "false" です。これは、AbstractMessageSource.receive()
メソッドがfind()
メソッドを使用することを意味します。'true' に設定すると、AbstractMessageSource.receive()
はfindOne(Query, Class)
を使用し、返されるMessage
のペイロードは、リストではなくentityClass
で識別される型の返されるターゲットオブジェクトになります。- パラメーター:
expectSingleResult
- 単一の結果が期待される場合は true。
setCollectionNameExpression
Query
で使用されるコレクション名に解決される SpELExpression
を設定します。結果のコレクション名は、MongoHeaders.COLLECTION_NAME
ヘッダーに含まれます。- パラメーター:
collectionNameExpression
- コレクション名の式。
setMongoConverter
MongoDb から読み取られたデータの逆直列化を支援するために使用されるカスタムMongoConverter
を提供します。- パラメーター:
mongoConverter
- mongo コンバーター。
setUpdateExpression
コレクションからポーリングされたレコードに対して、オプションのupdate
を指定します。- パラメーター:
updateExpression
-UpdateDefinition
の SpEL 式。- 導入:
- 5.5
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware
のsetApplicationContext
- 例外:
BeansException
getCollectionNameExpression
getMongoConverter
getEntityClass
isExpectSingleResult
public boolean isExpectSingleResult()getUpdateExpression
getApplicationContext
setInitialized
protected void setInitialized(boolean initialized) isInitialized
protected boolean isInitialized()onInit
protected void onInit()- オーバーライド:
- クラス
AbstractExpressionEvaluator
のonInit
evaluateQueryExpression
evaluateCollectionNameExpression
getByIdInQuery
idForEntity
evaluateUpdateExpression