クラスの使用
org.springframework.integration.amqp.dsl.RabbitStreamMessageHandlerSpec
RabbitStreamMessageHandlerSpec を使用するパッケージ
org.springframework.integration.amqp.dsl 内の RabbitStreamMessageHandlerSpec 使用
修飾子と型クラス説明class修飾子と型メソッド説明RabbitStreamMessageHandlerSpec.confirmTimeout(long timeout) 確認結果のタイムアウトを設定します。RabbitStreamMessageHandlerSpec.headerMapper(AmqpHeaderMapper headerMapper) リクエストおよび応答ヘッダーをマッピングするためのカスタムAmqpHeaderMapperを設定します。RabbitStreamMessageHandlerSpec.headersMappedLast(boolean headersLast) メッセージが変換される前にヘッダーがマップされるか、後でマップされるかを決定します。RabbitStreamMessageHandlerSpec.mappedRequestHeaders(StringSE... headers) リクエストからMessageHeadersにマップする必要のあるヘッダー名を指定します。RabbitStream.outboundStreamAdapter(com.rabbitmq.stream.Environment environment, StringSE streamName) 初期RabbitStreamMessageHandlerSpec(アダプター) を作成します。RabbitStream.outboundStreamAdapter(RabbitStreamTemplate template) 初期RabbitStreamMessageHandlerSpec(アダプター) を作成します。RabbitStreamMessageHandlerSpec.sendFailureChannel(StringSE channel) 障害チャネルを設定します。RabbitStreamMessageHandlerSpec.sendFailureChannel(MessageChannel channel) 障害チャネルを設定します。RabbitStreamMessageHandlerSpec.sendSuccessChannel(StringSE channel) 成功チャネルを設定します。RabbitStreamMessageHandlerSpec.sendSuccessChannel(MessageChannel channel) 成功チャネルを設定します。RabbitStreamMessageHandlerSpec.sync(boolean sync) 確認を待つには true に設定します。