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
フィールドのサマリー
フィールド
修飾子と型フィールド説明
protected Expression queryExpression
クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターの概要
コンストラクター
修飾子コンストラクター説明
protected AbstractMongoDbMessageSource(Expression queryExpression)

メソッドのサマリー

修飾子と型	メソッド	説明
`protected StringSE`	`evaluateCollectionNameExpression()`
`protected Query`	`evaluateQueryExpression()`
`protected Update`	`evaluateUpdateExpression()`
`ApplicationContext`	`getApplicationContext()`
`protected Query`	`getByIdInQuery(CollectionSE<?> entities)`
`Expression`	`getCollectionNameExpression()`
`ClassSE<?>`	`getEntityClass()`
`MongoConverter`	`getMongoConverter()`
`Expression`	`getUpdateExpression()`
`protected org.springframework.data.util.Pair<StringSE,ObjectSE>`	`idForEntity(ObjectSE entity)`
`boolean`	`isExpectSingleResult()`
`protected boolean`	`isInitialized()`
`protected void`	`onInit()`
`void`	`setApplicationContext(ApplicationContext applicationContext)`
`void`	`setCollectionNameExpression(Expression collectionNameExpression)`	`Query` で使用されるコレクション名に解決される SpEL `Expression` を設定します。
`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

インターフェース org.springframework.integration.core.MessageSource から継承されたメソッド

getIntegrationPatternType

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

getComponentType

フィールドの詳細
- queryExpression
  protected final Expression queryExpression
コンストラクターの詳細
- AbstractMongoDbMessageSource
  protected AbstractMongoDbMessageSource(Expression queryExpression)
メソッドの詳細
- setEntityClass
  public void setEntityClass(ClassSE<?> entityClass)
  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
  public void setCollectionNameExpression(Expression collectionNameExpression)
  Query で使用されるコレクション名に解決される SpEL Expression を設定します。結果のコレクション名は、MongoHeaders.COLLECTION_NAME ヘッダーに含まれます。
  パラメーター:
  collectionNameExpression - コレクション名の式。
- setMongoConverter
  public void setMongoConverter(MongoConverter mongoConverter)
  MongoDb から読み取られたデータの逆直列化を支援するために使用されるカスタム MongoConverter を提供します。
  パラメーター:
  mongoConverter - mongo コンバーター。
- setUpdateExpression
  public void setUpdateExpression(Expression updateExpression)
  コレクションからポーリングされたレコードに対して、オプションの update を指定します。
  パラメーター:
  updateExpression - UpdateDefinition の SpEL 式。
  導入:
  5.5
- setApplicationContext
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
  次で指定:
  インターフェース ApplicationContextAware の setApplicationContext
  例外:
  BeansException
- getCollectionNameExpression
  public Expression getCollectionNameExpression()
- getMongoConverter
  public MongoConverter getMongoConverter()
- getEntityClass
  public ClassSE<?> getEntityClass()
- isExpectSingleResult
  public boolean isExpectSingleResult()
- getUpdateExpression
  public Expression getUpdateExpression()
- getApplicationContext
  public ApplicationContext getApplicationContext()
- setInitialized
  protected void setInitialized(boolean initialized)
- isInitialized
  protected boolean isInitialized()
- onInit
  protected void onInit()
  オーバーライド:
  クラス AbstractExpressionEvaluator の onInit
- evaluateQueryExpression
  protected Query evaluateQueryExpression()
- evaluateCollectionNameExpression
  protected StringSE evaluateCollectionNameExpression()
- getByIdInQuery
  protected Query getByIdInQuery(CollectionSE<?> entities)
- idForEntity
  protected org.springframework.data.util.Pair<StringSE,ObjectSE> idForEntity(ObjectSE entity)
- evaluateUpdateExpression
  @Nullable protected Update evaluateUpdateExpression()

クラス AbstractMongoDbMessageSource<T>

ネストされたクラスの要約

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

コンストラクターの概要