クラス RabbitStreamMessageHandlerSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<RabbitStreamMessageHandlerSpec,RabbitStreamMessageHandler>
org.springframework.integration.dsl.MessageHandlerSpec<RabbitStreamMessageHandlerSpec,RabbitStreamMessageHandler>
org.springframework.integration.amqp.dsl.RabbitStreamMessageHandlerSpec
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<RabbitStreamMessageHandler>、InitializingBean、Lifecycle、Phased、SmartLifecycle
public class RabbitStreamMessageHandlerSpec extends MessageHandlerSpec<RabbitStreamMessageHandlerSpec,RabbitStreamMessageHandler>
RabbitStreamMessageHandler のベース MessageHandlerSpec。
導入:
6.0
作成者:
Gary Russell

  • メソッドの詳細

    • headerMapper

      public RabbitStreamMessageHandlerSpec headerMapper(AmqpHeaderMapper headerMapper)
      リクエストおよび応答ヘッダーをマッピングするためのカスタム AmqpHeaderMapper を設定します。
      パラメーター:
      headerMapper - 使用する AmqpHeaderMapper。
      戻り値:
      この仕様。

    • mappedRequestHeaders

      public RabbitStreamMessageHandlerSpec mappedRequestHeaders(StringSE... headers)
      リクエストから MessageHeaders にマップする必要のあるヘッダー名を指定します。
      パラメーター:
      headers - リクエストヘッダー名。
      戻り値:
      この仕様。

    • headersMappedLast

      public RabbitStreamMessageHandlerSpec headersMappedLast(boolean headersLast)
      メッセージが変換される前にヘッダーがマップされるか、後でマップされるかを決定します。
      パラメーター:
      headersLast - ヘッダーを最後にマップする場合は true。
      戻り値:
      この仕様。
      関連事項:

    • sendSuccessChannel

      public RabbitStreamMessageHandlerSpec sendSuccessChannel(MessageChannel channel)
      成功チャネルを設定します。
      パラメーター:
      channel - チャンネル。
      戻り値:
      この仕様。

    • sendFailureChannel

      public RabbitStreamMessageHandlerSpec sendFailureChannel(MessageChannel channel)
      障害チャネルを設定します。送信に失敗した後、ErrorMessage がこのチャネルに送信され、例外のペイロードと失敗したメッセージが含まれます。
      パラメーター:
      channel - チャンネル。
      戻り値:
      この仕様。

    • sendSuccessChannel

      public RabbitStreamMessageHandlerSpec sendSuccessChannel(StringSE channel)
      成功チャネルを設定します。
      パラメーター:
      channel - チャンネル。
      戻り値:
      この仕様。

    • sendFailureChannel

      public RabbitStreamMessageHandlerSpec sendFailureChannel(StringSE channel)
      障害チャネルを設定します。送信に失敗した後、ErrorMessage がこのチャネルに送信され、例外のペイロードと失敗したメッセージが含まれます。
      パラメーター:
      channel - チャンネル。
      戻り値:
      この仕様。

    • sync

      public RabbitStreamMessageHandlerSpec sync(boolean sync)
      確認を待つには true に設定します。
      パラメーター:
      sync - 待つのは本当です。
      戻り値:
      この仕様。
      関連事項:

    • confirmTimeout

      public RabbitStreamMessageHandlerSpec confirmTimeout(long timeout)
      確認結果のタイムアウトを設定します。
      パラメーター:
      timeout - おおよそのタイムアウト。
      戻り値:
      この仕様。
      関連事項: