Spring Integration HttpServerErrorException$InternalServerError：500：超时内未收到回复

Question

我正在尝试使用窃听将一些数据复制到另一个通道。这是我的代码：

 @Bean
    public IntegrationFlow flow() {
     
            return IntegrationFlows.from(Http.inboundGateway("/foo")
                            .requestMapping(m -> m.methods(HttpMethod.POST)
                    .transform(Transformers.objectToString())
                    .enrichHeaders(h -> h.headerExpression())
                    .transform(new ObjectTransformation()).wireTap("subChannel")
                    .get();
    }

我也制作了一个订阅频道，也是一个loggerhandler

 @Bean
    public SubscribableChannel subscribeChannel() {
        return MessageChannels.publishSubscribe("subChannel")
                .get();
    }


    public LoggingHandler logger() {
        LoggingHandler logger = new LoggingHandler(Level.INFO);
        return logger;
    }

，我还创建了一个流程来记录复制数据：

 @Bean
    public IntegrationFlow subscribeFlow() {
        return IntegrationFlows.from("subChannel")
                .handle(logger()).get();
    }

我遇到了一个没有答复的错误：

org.springframework.web.client.HttpServerErrorException$InternalServerError: 500 : "No reply received within timeout"

我不知道它是错误的，任何解决方案？

Answer 1

解决方案
我在流程末端使用窃听（）的事实使流程出错，因为默认情况没有回复。因此，我不得不将.bridge（）添加到流中。
流应该如下：

@Bean
    public IntegrationFlow flow() {
     
            return IntegrationFlows.from(Http.inboundGateway("/foo")
                            .requestMapping(m -> m.methods(HttpMethod.POST)
                    .transform(Transformers.objectToString())
                    .enrichHeaders(h -> h.headerExpression())
                    .transform(new ObjectTransformation()).wireTap("subChannel").bridge()
                    .get();
    }

检查此帖子
https://stackoverflow.com/questions/62673629/timeout-timeout-on-replychannel-when-when-wiretap-is-used#:~: text= thex;