diff --git a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java index 6cfd805b8..dc5b6fc94 100644 --- a/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java +++ b/snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/timer/RetryTimerWheel.java @@ -54,7 +54,7 @@ public class RetryTimerWheel { public static synchronized void register(String idempotentKey, TimerTask task, Duration delay) { register(idempotentKey, hashedWheelTimer -> { - SnailJobLog.LOCAL.debug("加入时间轮. delay:[{}ms] taskType:[{}]", delay, idempotentKey); + SnailJobLog.LOCAL.debug("加入时间轮. delay:[{}ms] taskType:[{}]", delay.toMillis(), idempotentKey); timer.newTimeout(task, Math.max(delay.toMillis(), 0), TimeUnit.MILLISECONDS); }); }