@Bean
public IntegrationFlow reimInvJpaOutbound() {
return IntegrationFlows
.from("reimInvProcessChannel")
.handle(reimJpaHandlers.reimStgInsertJpaHandler())
.log()
.get();
}
@Component
@Transactional
public class ReIMJpaHandlers {
Logger logger = LoggerFactory.getLogger(this.getClass());
@PersistenceContext
protected EntityManager entityManager;
@Autowired
ReIMHistInvHdrStgRepository histRepo;
@Autowired
ReIMInvHdrStgRepository stgRepo;
@Autowired
ReIMErrInvHdrStgRepository errRepo;
String responseQueryString = "select * from RMS16DEV.TSC_IM_DOC_HEAD_TEMP where error_ind != null";
@Bean
public JpaUpdatingOutboundEndpointSpec reimStgInsertJpaHandler() {
System.out.println("Writing to reim stg");
return Jpa
.updatingGateway(entityManager)
.entityClass(TSC_IM_DOC_HEAD_TEMP.class)
;
}
@Bean
public JpaPollingChannelAdapter reimStgResponseJpaInboundAdapter() {
return Jpa
.inboundAdapter(entityManager)
.nativeQuery(responseQueryString)
.maxResults(100)
.get();
}
}
但我得到以下错误:
javax.persistence.TransactionRequiredException: No EntityManager with actual transaction available for current thread - cannot reliably process 'merge' call
at org.springframework.orm.jpa.SharedEntityManagerCreator$SharedEntityManagerInvocationHandler.invoke(SharedEntityManagerCreator.java:292) ~[spring-orm-5.1.5.RELEASE.jar:5.1.5.RELEASE]
at com.sun.proxy.$Proxy189.merge(Unknown Source) ~[na:na]
您的
@Component
@Transactional
public class ReIMJpaHandlers {
无所谓
@Bean
public JpaUpdatingOutboundEndpointSpec reimStgInsertJpaHandler() {
最后一个是bean,它存在于自己的生命周期中,所有方法调用都发生在@Transactional
上的ReIMJpaHandlers
之外。
您需要考虑为.handle(reimJpaHandlers.reimStgInsertJpaHandler())
配置TX管理器:
.handle(reimJpaHandlers.reimStgInsertJpaHandler(), e -> e.transactional())
假设你有一个带有transactionManager
名称的bean。
类中的@Transactional
适用于业务方法,但不适用于在创建bean时仅调用一次的@Bean
方法。