我正在寻找一种带有拆分/聚合的集成流程。我希望捕获处理程序抛出的异常,并逐个迭代拆分的所有元素,即使某些元素失败。当所有元素都抛出异常,并且捕获异常时,流程永远不会结束。请问我遗漏了什么?我如何才能达到聚合并结束此流程?
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;
}