请问,怎么写才能做到先提交事务,再发送消息(activeMQ)

现在想实现一个功能,后台新增商品的同时,把新增商品的信息同步至索引库。
但是如果把发送消息的代码加到新增商品的方法里,因为最后一句是resalut ok(),所以会导致还未提交事务,就先发送了消息,此时发送的消息是空。导致报空指针错误。我把新增方法和发消息的代码装在一个新的方法里。但并未解决问题。
图片说明

把发消息的部分抽出成方法,然后在该方法中先调用新增保存方法,在获取消息的参数来发消息

代码不完整,看不出哪里错了,你要自己debug找到空指针对象,然后在想想为啥这个对象回空。