Spring Integration Java DSL中ExecutorChannel错误通道的处理

Question

例如，在我的用例中，我有一个队列（大小为100以限制输入）供调用方发送事件，轮询器将轮询队列并发送到executorchannel以进行异步处理（假设处理是CPU密集型的，我们将任务执行器的池大小限制在2）。异步处理的结果将发回给调用方。此外，如果有异常抛出异步处理。原始调用方将处理异常，而不是让全局错误处理程序来处理它。

我不知道如何在Spring Integration Java DSL中指定一个只有调用方才能看到从ExecutorChannel抛出的错误并以私有方式处理的通道。

Answer 1

为此，您必须为某些messagechannel指定errorchannel标头，这完全取决于您的调用方。

ExecutorChannel基于MessagePublishingErrorHandler，其代码如下：

private MessageChannel resolveErrorChannel(Throwable t) {
    Message<?> failedMessage = (t instanceof MessagingException) ?
            ((MessagingException) t).getFailedMessage() : null;
    if (this.defaultErrorChannel == null && this.channelResolver != null) {
        this.defaultErrorChannel = this.channelResolver.resolveDestination(
                IntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME);
    }

    if (failedMessage == null || failedMessage.getHeaders().getErrorChannel() == null) {
        return this.defaultErrorChannel;
    }
    Object errorChannelHeader = failedMessage.getHeaders().getErrorChannel();
    if (errorChannelHeader instanceof MessageChannel) {
        return (MessageChannel) errorChannelHeader;
    }
    Assert.isInstanceOf(String.class, errorChannelHeader,
            "Unsupported error channel header type. Expected MessageChannel or String, but actual type is [" +
            errorChannelHeader.getClass() + "]");
    return this.channelResolver.resolveDestination((String) errorChannelHeader);
}

注意包含failedmessage.getheaders().geterrorchannel()的部分。