我们有一个由
pseudoTransactionManager
界定的文件轮询器流程,用于在处理结束时根据成功或失败移动/删除输入文件。在处理这个巨大的文件时,我们希望在流程之间多次更新数据库中的处理统计信息,但是 Jpa
更新不会提交,因为它是文件事务范围的一部分。
我们如何为
Jpa.updatingGateway
定义一个单独的独立交易范围?谢谢
.handle(Jpa.updatingGateway(entityManagerFactory)
.entityClass(SomeDAO.class)
.flush(true),
ConsumerEndpointSpec::transactional)