From 6fff77dfa0227e3fc3b855ef1b0865b16839fc1a Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Wed, 16 Nov 2022 22:25:35 +0800 Subject: [PATCH] =?UTF-8?q?version:=200.0.4.2=20=E5=8F=91=E5=B8=83?= =?UTF-8?q?=E6=AD=A3=E5=BC=8F=E7=89=880.0.4.2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: byteblogs168 <598092184@qq.com> --- .../client/core/intercepter/RetryAspect.java | 20 +------------------ 1 file changed, 1 insertion(+), 19 deletions(-) diff --git a/x-retry-client-core/src/main/java/com/x/retry/client/core/intercepter/RetryAspect.java b/x-retry-client-core/src/main/java/com/x/retry/client/core/intercepter/RetryAspect.java index 3ce83db6f..af7720272 100644 --- a/x-retry-client-core/src/main/java/com/x/retry/client/core/intercepter/RetryAspect.java +++ b/x-retry-client-core/src/main/java/com/x/retry/client/core/intercepter/RetryAspect.java @@ -122,25 +122,7 @@ public class RetryAspect { return null; } - if (!TransactionSynchronizationManager.isActualTransactionActive()) { - // 无事务, 开启重试 - 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; - } + return openRetry(point, traceId, retryable, executorClassName, throwable); } private RetryerResultContext openRetry(ProceedingJoinPoint point, String traceId, Retryable retryable, String executorClassName, Throwable throwable) {