關(guān)于MQ異步調(diào)用，調(diào)用失敗的處理方式

@Transactional
void a(){
  b();//插入數(shù)據(jù)a,id=101
  c(101);
}

/*
* 異步執(zhí)行
*/
@Async
void c(int id){
  // 查詢
  Obj data = query(id);
  // 調(diào)用mq 
 push(data)
}

在一個(gè)事務(wù)里面，插入數(shù)據(jù)，然后在另一個(gè)線程里查詢并推送數(shù)據(jù)。

這里query的時(shí)候，可能由于事務(wù)沒有提交，查詢不到數(shù)據(jù)的。

問題

mq異步調(diào)用失敗，如何保證數(shù)據(jù)一致性？

已知方案：調(diào)用失敗寫入數(shù)據(jù)庫，然后定時(shí)掃表，做補(bǔ)償，不過感覺這種效率不高。

還有其他更好的方案嗎？