我不太确定该怎么做。但我正在寻找一种方法来分离函数的事务。
我有一个监听器来处理每条消息的结果(messageListener)。在将其发送到下一步(sendToNextProcess)之前,我想确保第一个事务(updateMessagesResults)成功。(也许可以创建一个单独的事务?)
我如何在Java Spring上做到这一点?谢谢
public void messageListener(List<Message> messages) {
resultUpdater.updateMessagesResults(messages);
sendToNextProcess(messages);
}注意:监听程序和resultUpdater都有@Transactional注释。
谢谢!
发布于 2020-04-08 16:03:56
在sendToNextProcess和updateMessagesResults上添加REQUIRES_NEW
不要直接调用sendToNextProcess,因为它不会工作。您应该注入当前的服务,并像这样调用它。
@Service
public CurrentService {
@Autowire
CurrentService CurrentService;
@Transactional
public void messageListener(List<Message> messages) {
resultUpdater.updateMessagesResults(messages);
currentService.sendToNextProcess(messages);
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void sendToNextProcess(List<Message> messages) {
}
}为什么应该从注入的服务调用它,因为@transactional试图从类范围之外包装它,然后尝试用this调用它,它不会像您预期的那样工作
https://stackoverflow.com/questions/61094773
复制相似问题