クラス MongoDbStoringMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.mongodb.outbound.MongoDbStoringMessageHandler
実装済みのインターフェース一覧:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
public class MongoDbStoringMessageHandler extends AbstractMessageHandler
collectionNameExpression の評価によって識別される MongoDb コレクションにメッセージペイロードを書き込む MessageHandler の実装。
導入:
2.2
作成者:
Amol Nayak, Oleg Zhurakousky, Gary Russell

  • コンストラクターの詳細

    • MongoDbStoringMessageHandler

      public MongoDbStoringMessageHandler(MongoDatabaseFactory mongoDbFactory)
      提供された MongoDatabaseFactory を使用してこのインスタンスを構築します。
      パラメーター:
      mongoDbFactory - mongodb ファクトリ。

    • MongoDbStoringMessageHandler

      public MongoDbStoringMessageHandler(MongoOperations mongoTemplate)
      提供された MongoOperations の完全に作成および初期化されたインスタンスを使用してこのインスタンスを構築します。
      パラメーター:
      mongoTemplate - MongoOperations 実装。

  • 方法の詳細

    • setMongoConverter

      public void setMongoConverter(MongoConverter mongoConverter)
      MongoDb に書き込まれたデータの直列化を支援するために使用されるカスタム MongoConverter の提供を許可します。このインスタンスが MongoDatabaseFactory で構築された場合にのみ許可されます。
      パラメーター:
      mongoConverter - mongo コンバーター。

    • setCollectionNameExpression

      public void setCollectionNameExpression(Expression collectionNameExpression)
      MongoOperations がデータを格納するために使用するコレクション名に解決される SpEL Expression を設定します
      パラメーター:
      collectionNameExpression - コレクション名の式。

    • getComponentType

      public StringSE getComponentType()
      次で指定:
      インターフェース NamedComponent 内の getComponentType 
      オーバーライド:
      クラス MessageHandlerSupport の getComponentType 

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス IntegrationObjectSupport の onInit 

    • handleMessageInternal

      protected void handleMessageInternal(Message<?> message)
      次で指定:
      クラス AbstractMessageHandler の handleMessageInternal