パッケージ org.springframework.integration.gateway

クラス GatewayMessageHandler

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.gateway.GatewayMessageHandler
実装済みのインターフェース一覧:
org.reactivestreams.Subscriber<Message<?>>、Aware、BeanClassLoaderAware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、MessageProducer、HeaderPropagationAware、IntegrationPattern、NamedComponent、IntegrationManagement、ManageableLifecycle、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>
public class GatewayMessageHandler extends AbstractReplyProducingMessageHandler implements ManageableLifecycle
ミッドフローゲートウェイの AbstractReplyProducingMessageHandler 実装。
導入:
5.0
作成者:
Artem Bilan, Christian Tzolov

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

    • GatewayMessageHandler

      public GatewayMessageHandler()

  • 方法の詳細

    • setRequestChannel

      public void setRequestChannel(MessageChannel requestChannel)

    • setRequestChannelName

      public void setRequestChannelName(StringSE requestChannel)

    • setReplyChannel

      public void setReplyChannel(MessageChannel replyChannel)

    • setReplyChannelName

      public void setReplyChannelName(StringSE replyChannel)

    • setErrorChannel

      public void setErrorChannel(MessageChannel errorChannel)

    • setErrorChannelName

      public void setErrorChannelName(StringSE errorChannel)

    • setRequestTimeout

      public void setRequestTimeout(LongSE requestTimeout)

    • setReplyTimeout

      public void setReplyTimeout(LongSE replyTimeout)

    • setErrorOnTimeout

      public void setErrorOnTimeout(boolean errorOnTimeout)

    • setAsyncExecutor

      public void setAsyncExecutor(@Nullable ExecutorSE executor)
      ゲートウェイメソッドが FutureSE または CompletableFutureSE を返すときに使用する executor を設定します。これを null に設定して非同期処理を無効にします。FutureSE 戻り値の型はすべてダウンストリームフローによって返される必要があります。
      パラメーター:
      executor - エグゼキューター。

    • handleRequestMessage

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

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle 内の start 
      次で指定:
      インターフェース ManageableLifecycle 内の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle 内の stop 
      次で指定:
      インターフェース ManageableLifecycle 内の stop 

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle 内の isRunning 
      次で指定:
      インターフェース ManageableLifecycle 内の isRunning