|
对于最新的稳定版本，请使用 Spring Integration 6.3.1！ |
|
对于最新的稳定版本，请使用 Spring Integration 6.3.1！ |
从 V5.3 开始，a 可用于生成回复的请求消息处理程序。
必须为此建议提供 A，并且根据截获的方法实现产生的回复从操作员调用它。
通常，当我们想通过 和类似的支持运营商控制网络波动时，这种自定义是必要的。
例如，当我们可以通过 WebFlux 客户端发出 HTTP 请求时，我们可以使用以下配置来等待响应的时间不超过 5 秒：ReactiveRequestHandlerAdviceMonoBiFunction<Message<?>, Mono<?>, Publisher<?>>Mono.transform()handleRequestMessage()Monotimeout()retry()
.handle(WebFlux.outboundGateway("https://somehost/"),
e -> e.customizeMonoReply((message, mono) -> mono.timeout(Duration.ofSeconds(5))));该参数是消息处理程序的请求消息，可用于确定请求范围属性。
该参数是此消息处理程序的方法实现的结果。
也可以从此函数调用嵌套来应用，例如，无功断路器。messagemonohandleRequestMessage()Mono.transform()