feat(1.5.0-beta1): 修复重试时间轮日志信息
This commit is contained in:
parent
8a1dc0d5b1
commit
2f03c7f1cd
@ -54,7 +54,7 @@ public class RetryTimerWheel {
|
|||||||
public static synchronized void register(String idempotentKey, TimerTask<String> task, Duration delay) {
|
public static synchronized void register(String idempotentKey, TimerTask<String> task, Duration delay) {
|
||||||
|
|
||||||
register(idempotentKey, hashedWheelTimer -> {
|
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);
|
timer.newTimeout(task, Math.max(delay.toMillis(), 0), TimeUnit.MILLISECONDS);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user