当一个特定的错误发生时，如何使用WebFlux在Spring Integration中定制响应？

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

@ControllerAdvice
public class CustomExceptionHandler implements WebExceptionHandler {

    @Override
    public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
        if (ex instanceof SpecificException) {
            // 处理特定的错误类型
            // 返回自定义的响应信息
            ServerHttpResponse response = exchange.getResponse();
            response.setStatusCode(HttpStatus.BAD_REQUEST);
            response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
            String responseBody = "{\"message\":\"特定错误发生了\"}";
            DataBuffer buffer = response.bufferFactory().wrap(responseBody.getBytes(StandardCharsets.UTF_8));
            return response.writeWith(Mono.just(buffer));
        } else {
            // 对于其他错误类型，可以继续使用默认的异常处理逻辑
            return Mono.error(ex);
        }
    }
}

@Configuration
public class WebFluxConfiguration {

    @Bean
    public IntegrationFlow errorFlow() {
        return IntegrationFlows.from(WebFlux.inboundGateway("/error")
                .errorChannel("errorChannel"))
                .bridge(e -> e.id("webFluxBridge"))
                .channel(MessageChannels.flux())
                .get();
    }

    @Bean
    public IntegrationFlow integrationFlow() {
        return IntegrationFlows.from("errorChannel")
                .handle(this::handleError)
                .get();
    }

    private void handleError(Message<?> message) {
        // 处理错误信息
        // 可以根据需要进行日志记录、异常处理等操作
    }
}