クラス AbstractReplyProducingMessageHandler

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>AwareBeanClassLoaderAwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationContextAwareOrderedExpressionCapableOrderableMessageProducerHeaderPropagationAwareIntegrationPatternNamedComponentIntegrationManagementTrackableComponentMessageHandlerreactor.core.CoreSubscriber<Message<?>>
既知の直属サブクラス
AbstractAmqpOutboundEndpointAbstractHttpRequestExecutingMessageHandlerAbstractMessageSplitterAbstractRemoteFileOutboundGatewayAbstractReplyProducingPostProcessingMessageHandlerAbstractWebServiceOutboundGatewayBarrierMessageHandlerBridgeHandlerCamelMessageHandlerCassandraMessageHandlerContentEnricherDelayHandlerFileWritingMessageHandlerGatewayMessageHandlerGraphQlMessageHandlerJdbcOutboundGatewayJmsOutboundGatewayJpaOutboundGatewayKafkaProducerMessageHandlerMessageTransformingHandlerMongoDbOutboundGatewayOperationInvokingMessageHandlerRedisOutboundGatewayRedisQueueOutboundGatewayReplyProducingMessageHandlerWrapperRSocketOutboundGatewayScatterGatherHandlerServiceActivatingHandlerStoredProcOutboundGatewayTcpOutboundGateway

public abstract class AbstractReplyProducingMessageHandler extends AbstractMessageProducingHandler implements BeanClassLoaderAware
返信を生成できる MessageHandlers の基本クラス。
作成者:
Mark Fisher, Iwein Fuld, Oleg Zhurakousky, Gary Russell, Artem Bilan, David Liu, Trung Pham, Christian Tzolov
  • コンストラクターの詳細

    • AbstractReplyProducingMessageHandler

      public AbstractReplyProducingMessageHandler()
  • メソッドの詳細

    • setRequiresReply

      public void setRequiresReply(boolean requiresReply)
      返信が必要かどうかのフラグ。true の場合、受信メッセージは応答メッセージの送信につながる必要があります。false の場合、受信メッセージにより、返信メッセージが送信される場合があります。デフォルトは false です。
      パラメーター:
      requiresReply - 返信が必要な場合は true。
    • getRequiresReply

      protected boolean getRequiresReply()
    • setAdviceChain

      public void setAdviceChain(ListSE<Advice> adviceChain)
      handleRequestMessage(Message) メソッドをプロキシする Advice のリストを構成します。
      パラメーター:
      adviceChain - 使用する Advice のリスト。
    • hasAdviceChain

      protected boolean hasAdviceChain()
    • setBeanClassLoader

      public void setBeanClassLoader(ClassLoaderSE beanClassLoader)
      次で指定:
      インターフェース BeanClassLoaderAwaresetBeanClassLoader 
    • getBeanClassLoader

      protected ClassLoaderSE getBeanClassLoader()
    • getIntegrationPatternType

      public IntegrationPatternType getIntegrationPatternType()
      インターフェースからコピーされた説明: IntegrationPattern
      このコンポーネントが実装するパターン型を返します。
      次で指定:
      インターフェース IntegrationPatterngetIntegrationPatternType 
      オーバーライド:
      クラス MessageHandlerSupportgetIntegrationPatternType 
      戻り値:
      このコンポーネントが実装する IntegrationPatternType
    • onInit

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

      protected void doInit()
    • handleMessageInternal

      protected final void handleMessageInternal(Message<?> message)
      次で指定:
      クラス AbstractMessageHandlerhandleMessageInternal 
    • doInvokeAdvisedRequestHandler

      @Nullable protected ObjectSE doInvokeAdvisedRequestHandler(Message<?> message)
    • handleRequestMessage

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