0

我试图通过读取来自每次通过单独线程触发的活动 mq 的消息来在表上插入和更新。有时插入查询会因为 ConstraintVoilationException 而失败。我想重试,因为代码会将重试尝试视为更新,并且不会出现 ConstraintVoilationException。

但是,RetryPolicy 并未处理此异常。我该如何定制它?

故障保护神器版本:net.jodah (2.3.3)

这是代码示例,其中“T”是我的实体的类名。

@Transactional
processTxn(T t){
 RetryPolicy<T> rp =  RetryPolicy<T>.handle(ConstraintVoilationException.class).withMaxRetries(3);
 Failsafe.with(rp).run(() -> insertOrUpdateMethod(t));
}

@Transactional
insertOrUpdateMethod (T t){
 //Fetch instance of t from DB, if it exists - fire update on a few columns
 //else insert a new row
}

我也用 DataIntegrityVoilationException 和 SQLIntegrityConstraintVoilationException 尝试了这段代码,但代码在失败后不会重试。

4

0 回答 0