gpt4 book ai didi

exception - Spring Integration-自定义errorChannel-仅记录第一个异常

转载 作者:行者123 更新时间:2023-12-03 08:44:16 27 4
gpt4 key购买 nike

这是对上一个问题(原始问题中的要求)的跟进。

Spring Integration - Filter - Send messages to a different end point

我的问题是,如果输入文件中有多个错误,则只会记录第一个错误。后续错误未记录。

修改后的代码:

@Configuration
public class CreateUserConfiguration {
@Bean
public IntegrationFlow createUser() {
return IntegrationFlows.from(Files.inboundAdapter(new File(INPUT_DIR)))
.enrichHeaders(h -> h.header("errorChannel", "exceptionChannel", true))
.transform(csvToUserBeanTransformer, "convertCsvToUserBean")
.split(userBeanSplitter, "splitUserBeans")
.wireTap(flow -> flow.<UserBean>filter(userBean -> !userBean.getStatus().equalsIgnoreCase("SUCCESS")).channel("errorSummaryReportGenerationChannel"))
.transform(userBeanToJSONTransformer, "convertUserBeanToJSON")
.handle(Files.outboundAdapter(new File(OUTPUT_SUCCESS_DIRECTORY)))
.get();
}

@Bean
public IntegrationFlow logErrorSummary() {
return IntegrationFlows.from("errorSummaryReportGenerationChannel")
.handle((p,h) -> {
return ((UserBean)(p)).getUserID() + "\t" + ((UserBean)(p)).getStatus();
})
.transform(Transformers.objectToString())
.handle(Files.outboundAdapter(new File(OUTPUT_FAILED_REPORT_FILE_NAME)))
.get();
}

@Bean
public IntegrationFlow logError() {
return IntegrationFlows.from("exceptionChannel")
.enrichHeaders(h -> h.headerExpression("errorFileName", "payload.failedMessage.headers.fileName"))
.wireTap(flow -> flow.handle(msg -> System.out.println("Received on exceptionChannel " + msg.getHeaders().get("errorFileName"))))
.transform(Transformers.objectToString())
.handle(Files.outboundAdapter(new File(generateOutputDirectory(OUTPUT_FAILED_DIRECTORY))).autoCreateDirectory(true).fileExistsMode(FileExistsMode.APPEND).fileNameExpression("getHeaders().get(\"errorFileName\")+'.json'"))
.get();
}

@Bean(name = "exceptionChannel")
MessageChannel exceptionChannel() {
return MessageChannels.executor(new SimpleAsyncTaskExecutor()).get();
}

@Bean(name="errorSummaryReportGenerationChannel")
MessageChannel errorSummaryReportGenerationChannel() {
return DirectChannel();
}
}

我的期望:

在errorSummaryReport中-
B123  ERROR, FREQUENCY
C123 FREQUENCY_DETAIL

在OUTPUT_FAILED_DIRECTORY中-
B123.json -> stacktrace of error
C123.json -> stacktrace of error

我看到的是:(缺少C123信息)

在errorSummaryReport中-
B123  ERROR, FREQUENCY

在OUTPUT_FAILED_DIRECTORY中-
B123.json -> stacktrace of error

最佳答案

问题从.split(userBeanSplitter, "splitUserBeans") pop 。

我要说的是,这完全类似于我们使用for循环在普通Java中所做的工作。
因此,如果循环中的方法引发异常,则您确实会远离循环,并且不再处理下一项。

要解决您的问题,您需要添加.channel(c -> c.executor(myExecutor()))来并行处理拆分的项目,并在单独的线程中进行错误处理。这样,分离器中的循环将不会受到影响。

关于exception - Spring Integration-自定义errorChannel-仅记录第一个异常,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58120142/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com