问如何使用java DSL在Spring集成中创建自定义错误响应

EN

@SpringBootApplication
@EnableIntegration
public class IntegrationApp {


@Value("${narko.pin}")
private String pinUrl;



public static void main(String[] args) {
    SpringApplication.run(MinzdravApplication.class, args);
}

@Bean
public DirectChannel requestPinChannel() {
    return new DirectChannel();
}

@Bean
public DirectChannel replyPinChannel() {
    return new DirectChannel();
}



@Bean
public IntegrationFlow httpProxyFlowPin() throws Exception {
    return IntegrationFlows
            .from(Http.inboundGateway("/narko/api/patient/by-pinpp")
                    .requestChannel(requestPinChannel()).replyChannel(replyPinChannel())
                    .mappedRequestHeaders("activityid")
                    .errorChannel("httpProxyErrorFlow.input")
             )
            .wireTap(sf->sf.handle(new InwardMessageHandler()))
            .enrichHeaders(h -> h.header("Content-Type", "application/json"))
            .handle(Http.outboundGateway(pinUrl).charset("utf-8")
                    .expectedResponseType(String.class))
            .channel(replyPinChannel())
            .get();
}


@Bean
public IntegrationFlow httpProxyErrorFlow() {
    return f -> f
            .transform(Throwable::getCause)
            .<HttpClientErrorException>handle((p, h) ->
                    new RuntimeException("custom exception"));
}

{
   "timestamp": "2022-08-10T12:51:58.561+00:00",
   "status": 500,
   "error": "Internal Server Error",
   "path": "/narko/api/patient/by-pinpp"
}

java.lang.ClassCastException: class org.springframework.web.client.ResourceAccessException cannot be cast to class org.springframework.web.client.HttpClientErrorException (org.springframework.web.client.ResourceAccessException and org.springframework.web.client.HttpClientErrorException are in unnamed module of loader 'app')
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na]
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:na]
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na]
at java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na]
at org.springframework.integration.handler.LambdaMessageProcessor.processMessage(LambdaMessageProcessor.java:104) ~[spring-integration-core-5.5.10.jar:5.5.10]
at org.springframework.integration.handler.ServiceActivatingHandler.handleRequestMessage(ServiceActivatingHandler.java:105) ~[spring-integration-core-5.5.10.jar:5.5.10]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:136) ~[spring-integration-core-5.5.10.jar:5.5.10]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.10.jar:5.5.10]
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.10.jar:5.5.10]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.10.jar:5.5.10]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.10.jar:5.5.10]