HttpRequestExecutingMessageHandler:没有可用的输出通道或replyChannel标头

Question

我在应用程序中收到一个错误，我没有得到解决方案。应用程序请求REST/JSON并尝试与另一个应用程序通信。有一个轮询器可以异步调用每个请求。当一个do a请求总是分派错误“没有可用的输出通道或replyChannel头”，它被重定向到errorChannel句柄。

...
@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerMetadata poller() {
    return Pollers              
            .fixedRate(NumberUtils.createLong(QUEUE_RATE))
            .get();
}

    @Bean
public MessageChannel errorChannel() {
    return MessageChannels.direct().get();
}

    @MessagingGateway 
public static interface HttpService {
    @Gateway(requestChannel = "service.input")
    void send(@Payload String body, @Headers MultiValueMap<String, String> headers);        
}


public MessageHandler httpOutboundAdapter(){
    HttpRequestExecutingMessageHandler handler = 
            Http.outboundGateway(URI, restTemplate)             
            .expectedResponseType(String.class)         
            .httpMethod(HttpMethod.POST)
            .mappedRequestHeaders("Authorization","Accept","Content-Type", "X-User-Email","X-User-Token")               
            .get();

    return handler;
}


@Bean
public FileWritingMessageHandler fileOutboundAdapter(){
    FileWritingMessageHandler fwmhs = Files
            .outboundAdapter(new File("logs/errors"))
            .autoCreateDirectory(true)
            .get();     

    return fwmhs;
}   

    @Bean
public IntegrationFlow send(){  
    return IntegrationFlows.from("service.input")
            .log(Level.DEBUG, "trace.http",
                    "'Request.\n'"+
                    ".concat('Headers : ').concat(headers.toString()).concat('\n')"+
                    ".concat('Payload : ').concat(payload.toString())"
                )                               
            .channel(MessageChannels.queue())
            .handle(this.httpOutboundAdapter()
            .transform(Transformers.toJson())
            .log(Level.DEBUG, "trace.http",
                    "'Response.\n'"+
                    ".concat('Headers : ').concat(headers.toString()).concat('\n')"+
                    ".concat('Payload : ').concat(payload.toString())"
                )
            .get();
}

    @Bean 
public IntegrationFlow errorFlow(){
    return IntegrationFlows.from(errorChannel())                                                                
                            .log(Level.DEBUG,"trace.http", "'Ocurred an error in httpResponse :'.concat(payload.message)")
                            .transform("payload.failedMessage")                             
                            .handle((p,h) -> 
                                        MessageBuilder.withPayload(new GenericMessage<>(p,h)))
                            .transform(Transformers.toJson())
                            .enrichHeaders(c -> c.headerExpression(FileHeaders.FILENAME, "'emailErrors-'.concat(headers.getTimestamp()).concat('.json')"))
                            .handle(fileOutboundAdapter())                              
                            .get();
}

日志打印：

后发送（发送=true）在通道'错误通道'，消息：错误消息[有效载荷=org.springframework.messaging.消息异常：调度程序未能传递消息；嵌套异常是org.springframework.messaging.core.目标解决异常：没有可用的输出通道或回复通道标头，标头={id=826074c0-d1c6-4ecf-44f0-6da697b29f9c，时间戳=1484650523378}]

Gary Russel sugestion之后的更新

...

@Bean
public IntegrationFlow send(){  
    return IntegrationFlows.from("service.input")
            .log(Level.DEBUG, "trace.http",
                    "'Request.\n'"+
                    ".concat('Headers : ').concat(headers.toString()).concat('\n')"+
                    ".concat('Payload : ').concat(payload.toString())"
                )                               
            .channel(MessageChannels.queue())
            .handle(this.httpOutboundAdapter()
            .transform(Transformers.toJson())
            .log(Level.DEBUG, "trace.http",
                    "'Response.\n'"+
                    ".concat('Headers : ').concat(headers.toString()).concat('\n')"+
                    ".concat('Payload : ').concat(payload.toString())"
                )
            .channel("nullChanel")
            .get();
}

日志

2017-01-17 13:58:31.929 DEBUG 19702---[ASK调度器-9]o.s.integration.channel.DirectChannel：在通道send.channel#3上预发送，消息：GenericMessage[有效负载=$PAYLOAD_JSON，标头=$HEADERS] 2017-01-17 13:58:31.930 DEBUG 19702---[ASK-调度程序-9]o. s. i. t.MessageTransformingHandler：org.springframework.integration.transformer.MessageTransformingHandler#0收到消息：GenericMessage[有效载荷=$PAYLOAD_JSON，标头=$HEADERS] 2017-01-17 13:58:31.932 DEBUG 19702---[ask-调度器-9]o.s.integration.channel.DirectChannel： pre发送频道'send.channel#5'，消息：GenericMessage[有效载荷=$PAYLOAD_JSON，标头=$HEADERS] 2017-01-17 13:58:31.932 DEBUG 19702---[ask-调度器-9]o.s.integration.handler.LoggingHandler：org.springframework.integration.handler.LoggingHandler#1收到消息：GenericMessage GenericMessage[有效载荷=$PAYLOAD_JSON，标头=$HEADERS] 2017-01-17 13:58:31.942o.s.integration.handler.BridgeHandler：org.springframework.integration.handler.BridgeHandler#2收到消息：GenericMessage[有效负载=$PAYLOAD_JSON，标头=$HEADERS] 2017-01-17 13:58:31.943 DEBUG 19702---[ask-调度器-9]o.s.integration.channel.DirectChannel：在通道'nullChanel'上预发送，消息：GenericMessage[有效载荷=$PAYLOAD_JSON，报头=$HEADERS] 2017-01-17 13:58:31.944 DEBUG 19702---[ask调度器-9]o.s.integration.channel.DirectChannel：在通道'errorChannel'上预发送，消息：错误消息[有效载荷=org.springframework.messaging.消息传递例外：Dispatcher没有通道应用程序：29891.nullChanel的订阅者。；嵌套异常是org.springframework.integration.MessageDispatchingExc0019： Dispatcher没有订阅者，标头={id=fe0672cd-b9e4-9d43-2c5a-3d2d0a1c5493，时间戳=1484668711944}] 2017-01-17 13:58:31.945 DEBUG 19702---[请求调度器-9]o.s.integration.handler.LoggingHandler：org.springframework.integration.handler.LoggingHandler#2收到消息：错误消息[有效载荷=org.springframework.messaging.MessageDeliveryExc0019： Dispatcher没有订阅通道'应用程序：29891.nullChanel'。；嵌套异常是org.springframework.integration.MessageDispatchingExc0019：Dispatcher没有订阅者，标头={id=fe0672cd-b9e4-9d43-2c5a-3d2d0a1c5493，时间戳=1484668711944}] 2017-01-17 13:58:31.949 DEBUG 19702---[ASC-调度器-9]o. s. i. t.MessageTransformingHandler：org.springframework.integration.transformer.MessageTransformingHandler#1收到的消息：ErrorMessage[payload=org. springframework.消息。MessageDeliveryExc0019： Dispatcher没有订阅通道'应用程序： 29891. nullChanel'的用户。；嵌套异常是org. springframework.集成。MessageDispatchingExc0019： Dispatcher没有订阅者，标头={id=fe0672cd-b9e4-9d43-2c5a-3d2d0a1c5493，时间戳=1484668711944}] 2017-01-17 13:58:31.951 DEBUG 19702---[ask-调度器-9]o. s.集成. Channel。DirectChannel：在通道上预发'errorFlow. Channel#1'，消息：GenericMessage[有效载荷=$PAYLOAD_JSON，标头=$HEADERS]

我分别用$payload_JSON和$HEADERS替换了负载和头部，以减少日志。

Answer 1

您的网关有一个返回无效发送（...），因此框架不需要回复。

. log（）元素是一个窃听（这就是第一个日志让消息流向队列通道的方式）。

由于您的流以日志（wireTap）结束，所以它期待消息的消费者或回复通道。

我们可能会做最后的。登录终端并查看（INT-4210），但现在您可以添加。频道（“空频道”）在最后一个之后。日志。