version: 0.0.4.2

发布正式版0.0.4.2

Signed-off-by: byteblogs168 <598092184@qq.com>
This commit is contained in:
byteblogs168 2022-11-16 22:25:35 +08:00
parent 1cdece6f5e
commit 6fff77dfa0

View File

@ -122,25 +122,7 @@ public class RetryAspect {
return null; return null;
} }
if (!TransactionSynchronizationManager.isActualTransactionActive()) { return openRetry(point, traceId, retryable, executorClassName, throwable); }
// 无事务, 开启重试
return openRetry(point, traceId, retryable, executorClassName, throwable);
}
// final RetryerResultContext[] retryerResultContext = {null};
// 存在事物
// TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
//
// @Override
// public void afterCompletion(int status) {
// // 有事务开启重试
// retryerResultContext[0] = openRetry(point, traceId, retryable, executorClassName, throwable);
// }
// });
return null;
}
private RetryerResultContext openRetry(ProceedingJoinPoint point, String traceId, Retryable retryable, String executorClassName, Throwable throwable) { private RetryerResultContext openRetry(ProceedingJoinPoint point, String traceId, Retryable retryable, String executorClassName, Throwable throwable) {