Spring集成流程异步中的错误处理

Question

我具有以下Spring Integration配置，该配置允许我从MVC
Controller调用网关方法并让控制器返回，而集成流将在不阻塞控制器的单独线程中继续进行。

但是，我无法弄清楚如何使我的错误处理程序为该异步流工作。我的网关定义了错误通道，但是由于某种原因我的异常没有到达。相反，我看到LoggingHandler被调用了。

@Bean
IntegrationFlow mainInteractiveFlow() {
    return IntegrationFlows.from(
            MessageChannels.executor("input", executor))
            .split()
            .channel(MessageChannels.executor(executor))
            .transform(transformer)
            .handle(genericMessageHandler, "validate")
            .handle(genericMessageHandler, "checkSubscription")
            .handle(interactiveMessageService, "handle")
            .<Task, String>route(p -> p.getKind().name(),
                    m -> m.channelMapping(TaskKind.ABC.name(), "attachInteractiveChannel"))
            .get();
}

@Bean
IntegrationFlow attachInteractiveChannelFlow() {
    return IntegrationFlows.from(
            MessageChannels.direct("attachInteractiveChannel"))
            .handle(issueRouterService)
            .get();
}

@Bean
IntegrationFlow interactiveExceptionChannelFlow() {
    return IntegrationFlows.from(interactiveExceptionChannel())
            .handle(errorHandler, "handleErrorMessage")
            .get();
}

@Bean
MessageChannel interactiveExceptionChannel() {
    return MessageChannels.direct("interactiveExceptionChannel").get();
}

网关：

@MessagingGateway(errorChannel = "interactiveExceptionChannel")
public interface InteractiveSlackGW {

    @Gateway(requestChannel = "input")
    void interactiveMessage(Collection<Request> messages);

}

为了查看我的错误处理程序正在处理的异步集成流程中发生的异常，我该怎么办？

Answer 1

具有void返回的网关不希望收到答复，因此没有添加到消息标题的答复/错误通道。在调用线程上运行时，异常将引发给调用者；对于异步流，异常将变为默认值errorChannel（已附加日志适配器）。

在这种情况下，您需要添加头扩展程序，以将头设置为errorChannel错误通道。

我们应该考虑自动执行此操作，但是目前还没有发生。

我为此打开了JIRA问题。