java - 当 IdempotReceiverInterceptor 丢弃消息时流程挂起(在第 4 条消息之后)

Question

我有以下流程:

    return flow -> flow.channel(inputChannel())
             ... 
            .gateway(childFlow, addMyInterceptor(str)); // by name
}


Consumer<GatewayEndpointSpec> addMyInterceptor(String objectIdHeader) {
    return endpointSpec -> endpointSpec.advice(addMyInterceptorInternal(objectIdHeader))
            .errorChannel(errorChannel());
}

default IdempotentReceiverInterceptor addMyInterceptorInternal(String header) {
    MessageProcessor<String> headerSelector = message -> headerExpression(header).apply(message);
    var interceptor = new IdempotentReceiverInterceptor(new MetadataStoreSelector(headerSelector, idempotencyStore()));
    interceptor.setDiscardChannel(idempotentDiscardChannel());
    return interceptor;
}

当IdempotReceiverInterceptor遇到该消息重复时 - 我发现应用程序在第四条重复消息后挂起。我知道这是因为网关期望响应(如这里: PubSubInboundChannelAdapter stops to receive messages after 4th message )，但我不知道如何从拦截器返回结果。

你能帮我解释一下吗？

Answer 1

只要所有 channel 都是直接的(默认) - 即使用队列或执行器 channel 的流程中没有异步切换，当流程完成时，将网关的 replyTimeout 设置为 0可能不会返回回复