Início / coding / Perguntas / 79249387
Accepted
Médéric Martin
Asked: 2024-12-04 06:39:02 +0800 CST

Exceção de armadilha com divisor

  • 772

Estou procurando implementar um fluxo de integração com um split/aggregate. Gostaria de capturar lançamentos de exceção por manipuladores e iterar todos os elementos divididos um por um, mesmo se algum elemento falhar. Quando todos os elementos lançam exceção e as exceções são capturadas, o fluxo nunca termina. O que eu perdi, por favor? Como posso alcançar o agregado e o fim deste fluxo?

IntegrationFlow.from(
        WebFlux.inboundGateway("/jira/version")
                .requestMapping(r -> r.methods(HttpMethod.POST)
                        .consumes("application/json"))
                .requestPayloadType(String.class)
                .replyChannel(replyChannel)
                .errorChannel(errorChannel)
                .mappedRequestHeaders(parameter.getJiraHeaderSignature()))
.handle(versionWebhookHandler)
.split(new VersionIssueSplitter())
.handle(updateVersionHandler, s -> s.advice(advice()))
.aggregate()
.get();





public Advice advice() {
    var advice = new ExpressionEvaluatingRequestHandlerAdvice();
    advice.setTrapException(true);
    return advice;
}
spring-integration

1 respostas

  1. Best Answer

    Esta advice.setTrapException(true);é a maneira correta de não deixar que essa exceção borbulhe e permitir que o divisor itere naturalmente.

    Seu problema é com o .aggregate(). Embora seja muito conveniente que o divisor e o agregador funcionem em conjunto por padrão, você tem que garantir que realmente todos os elementos cheguem a esse agregador para completar o grupo de mensagens corretamente.

    Quando você captura (ou simplesmente captura) exceções no tratamento de itens, não há resposta para enviar disso handlepara aggregate. Então, um agregador não pode cumprir os requisitos de conclusão do grupo, portanto seu fluxo nunca termina.

    Não sabemos quais são suas expectativas, mas aparentemente você tem que emitir qualquer coisa de qualquer forma, mesmo que o tratamento de itens acabe com um erro. Você pode criar algum objeto personalizado para retornar de and failureExpressionem returnFailureExpressionResult = truevez de trapException. O manipulador então cuidará de envolver esse resultado em uma mensagem com cabeçalhos de detalhes de correlação adequados da solicitação.

    Então você pode dar uma olhada em:

    /**
 * A processor to determine the output message from the released group. Defaults to a message
 * with a payload that is a collection of payloads from the input messages.
 * @param outputProcessor the processor.
 * @return the aggregator spec.
 */
public AggregatorSpec outputProcessor(MessageGroupProcessor outputProcessor) {

    Para iterar sobre mensagens agrupadas e filtrar aquelas com erros, caso você não precise delas posteriormente.

    Veja mais informações sobre detalhes de correlação nos documentos: https://docs.spring.io/spring-integration/reference/aggregator.html

    • 0

relate perguntas