クラス MongoDbOutboundGateway

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>AwareBeanClassLoaderAwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationContextAwareOrderedExpressionCapableOrderableMessageProducerHeaderPropagationAwareIntegrationPatternNamedComponentIntegrationManagementTrackableComponentMessageHandlerreactor.core.CoreSubscriber<Message<?>>

public class MongoDbOutboundGateway extends AbstractReplyProducingMessageHandler
MongoOperations を使用して MongoDb データベースを照会する送信操作を行います。
導入:
5.0
作成者:
Xavier Padro, Artem Bilan
  • コンストラクターの詳細

  • メソッドの詳細

    • setQueryExpression

      public void setQueryExpression(Expression queryExpression)
    • setQueryExpressionString

      public void setQueryExpressionString(StringSE queryExpressionString)
    • setMessageCollectionCallback

      public void setMessageCollectionCallback(MessageCollectionCallback<?> collectionCallback)
      リクエストメッセージコンテキストで MongoDB コレクションに対して実行する MessageCollectionCallback を指定します。
      パラメーター:
      collectionCallback - MongoDB コレクションに対して実行するコールバック。
      導入:
      5.0.11
    • setExpectSingleResult

      public void setExpectSingleResult(boolean expectSingleResult)
    • setEntityClass

      public void setEntityClass(ClassSE<?> entityClass)
    • setCollectionNameExpression

      public void setCollectionNameExpression(Expression collectionNameExpression)
    • setCollectionNameExpressionString

      public void setCollectionNameExpressionString(StringSE collectionNameExpressionString)
    • setMongoConverter

      public void setMongoConverter(MongoConverter mongoConverter)
    • doInit

      protected void doInit()
      オーバーライド:
      クラス AbstractReplyProducingMessageHandlerdoInit 
    • handleRequestMessage

      protected ObjectSE handleRequestMessage(Message<?> requestMessage)
      クラスからコピーされた説明: AbstractReplyProducingMessageHandler
      サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。
      次で指定:
      クラス AbstractReplyProducingMessageHandlerhandleRequestMessage 
      パラメーター:
      requestMessage - リクエストメッセージ。
      戻り値:
      メッセージを処理した結果、または null