diff --git a/src/main/java/com/example/snailjob/handler/OnlyRemoteRetryHandler.java b/src/main/java/com/example/snailjob/handler/OnlyRemoteRetryHandler.java index 9ccb979..beb0b14 100644 --- a/src/main/java/com/example/snailjob/handler/OnlyRemoteRetryHandler.java +++ b/src/main/java/com/example/snailjob/handler/OnlyRemoteRetryHandler.java @@ -45,13 +45,13 @@ public class OnlyRemoteRetryHandler { } } - @Retryable(scene = "localRetryWithRequires", retryStrategy = RetryType.ONLY_LOCAL) + @Retryable(scene = "localRetryWithRequires", retryStrategy = RetryType.ONLY_REMOTE) public void localRetryWithRequires(String params) { System.out.println("local retry 方法开始执行"); double i = 1 / 0; } - @Retryable(scene = "localRetryWithRequiresNew", retryStrategy = RetryType.ONLY_LOCAL, propagation = Propagation.REQUIRES_NEW) + @Retryable(scene = "localRetryWithRequiresNew", retryStrategy = RetryType.ONLY_REMOTE, propagation = Propagation.REQUIRES_NEW) public void localRetryWithRequiresNew(String params) { System.out.println("local retry 方法开始执行"); double i = 1 / 0;