带有错误通道的 Spring Integration Async Gateway 导致线程停止

Question

我有一个异步网关，其中定义了一个异步执行器和一个错误通道。还有一个处理异常的服务激活器。

<int:gateway id="myGateway"
             service-interface="me.myGateway"
             default-request-channel="requestChannel"
             async-executor="taskScheduler"
             error-channel="errorChannel"/>

<int:service-activator ref="errorChannelMessageHandler" method="handleFailedInvocation"
                       input-channel="errorChannel"/>

public interface MyGateway {
    Future<Object> send(Message message);
}

@Component
public class ErrorChannelMessageHandler {
    @ServiceActivator
    public Object handleFailedInvocation(MessagingException exception) {
        // do some stuff here
        return null;
    }
}

当抛出异常时，线程阻塞，等待网关创建的临时回复通道上的回复。

如何防止线程阻塞以及何时引发异常以让错误通道服务激活器处理消息并执行一些自定义逻辑？

后期编辑： 我正在使用 SI 3.0.3.RELEASE 当为网关定义错误通道时，如果发生异常，它将调用此行（来自 MessagingGatewaySupport 的没有 250）errorFlowReply = this.messagingTemplate.sendAndReceive(this.errorChannel, errorMessage)，它将执行在新创建的临时回复通道上阻止接收（来自 MessagingTemplate 的第 352-367 行）。我的错误通道的服务激活器是否负责在这个新创建的临时通道上发布消息，因此线程不会阻塞接收？

Answer 1

删除错误通道，以便将原始异常添加到Future，以便get() 传播它。

如果您想对错误流执行某些操作，请从错误流中抛出异常，以便在 Future 中可用，或将 reply-timeout 设置为 0。但是，您的 Future 永远不会在那个案例。