feat(1.5.0-beta1): 修复重试时间轮日志信息
This commit is contained in:
parent
4ac26f3e47
commit
4d7dcbfd52
@ -54,7 +54,7 @@ public class RetryTimerWheel {
|
||||
public static synchronized void register(String idempotentKey, TimerTask<String> 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);
|
||||
});
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user