クラス MongoDbOutboundGateway

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.mongodb.outbound.MongoDbOutboundGateway
実装されているすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>、Aware、BeanClassLoaderAware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、MessageProducer、HeaderPropagationAware、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageHandler、reactor.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()
      オーバーライド:
      クラス AbstractReplyProducingMessageHandler の doInit 

    • handleRequestMessage

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