Fix timer

jd-opensource · Jan 10, 2025 · 559a210 · 559a210
1 parent 10901d1
commit 559a210
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...api/src/main/java/com/jd/live/agent/governance/invoke/filter/inbound/LoadLimitFilter.java b/...api/src/main/java/com/jd/live/agent/governance/invoke/filter/inbound/LoadLimitFilter.java
@@ -133,7 +133,7 @@ private void pass(InboundInvocation<?> invocation, SystemLoad threshold, SystemL
      * @param time the delay in milliseconds before the task is executed
      */
     private void addTask(long time) {
-        timer.add(LOAD_LIMITER_TIMER, time, this::compute);
+        timer.delay(LOAD_LIMITER_TIMER, time, this::compute);
     }
 
     /**

diff --git a/...com/jd/live/agent/implement/flowcontrol/ratelimit/redisson/client/RedisClientManager.java b/...com/jd/live/agent/implement/flowcontrol/ratelimit/redisson/client/RedisClientManager.java
@@ -67,7 +67,7 @@ private void removeClient(final RedisClient client) {
      * @param client the Redis client to be recycled
      */
     private void addTask(RedisClient client) {
-        timer.add("Recycle-RedisClient-" + client.getId(), 5000, () -> {
+        timer.delay("Recycle-RedisClient-" + client.getId(), 5000, () -> {
             if (client.isExpired(10000)) {
                 client.shutdown();
             } else {