クラス RabbitStreamMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.amqp.outbound.RabbitStreamMessageHandler
実装済みのインターフェース一覧:
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 RabbitStreamMessageHandler extends AbstractMessageHandler
RabbitStreamOperations に基づく MessageHandler。
導入:
6.0
作成者:
Gary Russell, Chris Bono, Ryan Riley

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

    • RabbitStreamMessageHandler

      public RabbitStreamMessageHandler(RabbitStreamOperations streamOperations)
      提供された RabbitStreamOperations を使用してインスタンスを作成します。
      パラメーター:
      streamOperations - 操作。

  • 方法の詳細

    • setSendFailureChannel

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

    • setSendFailureChannelName

      public void setSendFailureChannelName(StringSE sendFailureChannelName)
      障害チャネル名を設定します。送信に失敗した後、ErrorMessage がこのチャネルに送信され、例外のペイロードと失敗したメッセージが含まれます。
      パラメーター:
      sendFailureChannelName - 障害チャネル名。

    • setSendSuccessChannel

      public void setSendSuccessChannel(MessageChannel sendSuccessChannel)
      成功チャネルを設定します。
      パラメーター:
      sendSuccessChannel - 成功チャンネル。

    • setSendSuccessChannelName

      public void setSendSuccessChannelName(StringSE sendSuccessChannelName)
      成功チャンネル名を設定します。
      パラメーター:
      sendSuccessChannelName - 成功チャネル名。

    • setSync

      public void setSync(boolean sync)
      確認を待つには true に設定します。
      パラメーター:
      sync - 待つのは本当です。
      関連事項:

    • setConfirmTimeout

      public void setConfirmTimeout(long confirmTimeout)
      確認タイムアウトを設定します。
      パラメーター:
      confirmTimeout - タイムアウト。
      関連事項:

    • setHeaderMapper

      public void setHeaderMapper(AmqpHeaderMapper headerMapper)
      リクエストおよび応答ヘッダーをマッピングするためのカスタム AmqpHeaderMapper を設定します。デフォルトは DefaultAmqpHeaderMapper.outboundMapper() です。
      パラメーター:
      headerMapper - 使用する AmqpHeaderMapper。

    • setHeadersMappedLast

      public void setHeadersMappedLast(boolean headersMappedLast)
      送信メッセージのヘッダーをマッピングする場合、メッセージが変換される前にヘッダーをマッピングするか、その後にヘッダーをマッピングするかを決定します。これは、メッセージコンバーターによって追加される可能性のあるヘッダーにのみ影響します。false の場合、コンバーターのヘッダーが優先されます。true の場合、コンバーターによって追加されたヘッダーはオーバーライドされます（ソースメッセージにこれらのヘッダーにマップするヘッダーがある場合）。たとえば、json を含む String ペイロードで SimpleMessageConverter を使用する場合、これを true に設定できます。コンバーターは、AmqpHeaders.CONTENT_TYPE メッセージヘッダーを設定することにより、application/json に上書きできる text/plain にコンテンツ型を設定します。デフォルト: false。
      パラメーター:
      headersMappedLast - 変換後にヘッダーがマップされる場合は true。

    • getStreamOperations

      public RabbitStreamOperations getStreamOperations()
      RabbitStreamOperations を返します。
      戻り値:
      操作。

    • getSendFailureChannel

      protected @Nullable MessageChannel getSendFailureChannel()

    • getSendSuccessChannel

      protected @Nullable MessageChannel getSendSuccessChannel()

    • handleMessageInternal

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