如何处理 Java DSL 流中的错误处理?
假设我有一个写入 Rabbit(或数据库)的简单流程。
@Bean
public IntegrationFlow setupRabbitFlow() {
return IntegrationFlows.from(publishSubscribeChannel)
.handle((p, h) -> rabbitPublishActivator.publishToRabbit(p))
.get();
}
由于数据库问题或中间连接失败,此类操作可能会导致错误。
如果在“publishToRabbit”步骤中发生某些异常,我如何增强对所采取操作的流声明?