事务提交后发送 JMS 消息

Question

我有一个应用程序（app1），我正在与Hibernate和JMS合作。我有一种用@transactional注释的方法。此方法将数据插入数据库，然后将数据发送到MQ。 我正在遇到一个问题，即消费者应用程序（APP2）从MQ获取消息并调用App1，但是由于App1未完成数据库，因此返回一个错误，说找不到数据。

在发送JMS消息之前，有什么方法可以在数据库中提交数据库插入？

@Transactional
public void create(Data data){
     doSomeValidation();
     anotherClass.insertInDB(data.name, data.email);

     thirdClass.sendDataToMQ(data.id);
}

@Transactional
public void insertInDB(String name, String email) {
     Entity entity = new Entity();
     entity.setName(name);
     entity.setEmail(email);
     repository.saveAndFlush(entity)
}

@Transactional
public void sendDataToMQ(int id) {
     Entity entity = repository.findById(id);
     jmsTemplate.setSessionTransacted(true);
     jmsTemplate.convertAndSend(someDestination, new Message(entity)message -> {
                return message;
            });
    doSomeUpdateInDB(int id);
}