コンストラクターの詳細

• MongoDbMessageSource

  public MongoDbMessageSource(MongoDatabaseFactory mongoDbFactory,
                              Expression queryExpression)

  提供された MongoDatabaseFactory と SpEL 式を使用してインスタンスを作成します。このインスタンスは、MongoDb の「クエリ」文字列に解決されます (https://www.mongodb.org/display/DOCS/Querying) を参照)。"queryExpression" は、AbstractMessageSource.receive() メソッドが呼び出されるたびに評価されます。

  パラメーター:

  mongoDbFactory - mongodb ファクトリ。

  queryExpression - クエリ式。

• MongoDbMessageSource

  public MongoDbMessageSource(MongoOperations mongoTemplate,
                              Expression queryExpression)

  提供された MongoOperations と SpEL 式を使用してインスタンスを作成します。このインスタンスは、Mongo の「クエリ」文字列に解決されます (https://www.mongodb.org/display/DOCS/Querying) を参照)。MongoOperations が完全に初期化され、使用できる状態にあることを前提としています。"queryExpression" は、AbstractMessageSource.receive() メソッドが呼び出されるたびに評価されます。

  パラメーター:

  mongoTemplate - mongo テンプレート。

  queryExpression - クエリ式。

メソッドの詳細

• setEntityClass

  public void setEntityClass(ClassSE<?> entityClass)

  MongoTemplate.find(Query, Class) または MongoTemplate.findOne(Query, Class) メソッドに渡される entityClass の型を設定できます。デフォルトは DBObject です。

  パラメーター:

  entityClass - エンティティクラス。

• setExpectSingleResult

  public void setExpectSingleResult(boolean expectSingleResult)

  MongoTemplate で呼び出す find * メソッドを管理できます。デフォルトは "false" です。これは、AbstractMessageSource.receive() メソッドが MongoTemplate.find(Query, Class) メソッドを使用することを意味します。'true' に設定すると、AbstractMessageSource.receive() は MongoTemplate.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 を提供できます。このインスタンスが MongoDatabaseFactory で構築された場合にのみ許可されます。

  パラメーター:

  mongoConverter - mongo コンバーター。

• getComponentType

  public StringSE getComponentType()

• onInit

  protected void onInit()

  オーバーライド:

  クラス AbstractExpressionEvaluator の onInit 

• doReceive

  protected ObjectSE doReceive()

  Query を実行し、その結果をメッセージペイロードとして返します。ペイロードは、entityClass で識別された型のオブジェクトの要素を ListSE とするか、expectSingleResult 属性の値（デフォルトは 'false' ）に基づいて entityClass で識別された型の単一の要素を Message とし、ListSE 型のペイロードを返すかのいずれかです。クエリで使用されるコレクション名は、MongoHeaders.COLLECTION_NAME ヘッダーで指定されます。

  次で指定:

  クラス AbstractMessageSource<ObjectSE> の doReceive 

  戻り値:

  返された値。