Merge pull request #27074 from akka/wip-26932-timers-logging-patriknw
Remove too verbose debug logging for timers, #26932
This commit is contained in:
commit
937cbaf328
2 changed files with 0 additions and 2 deletions
|
|
@ -83,7 +83,6 @@ import akka.util.OptionVal
|
||||||
.scheduleOnce(delay, () => ctx.self.unsafeUpcast ! timerMsg)(ExecutionContexts.sameThreadExecutionContext)
|
.scheduleOnce(delay, () => ctx.self.unsafeUpcast ! timerMsg)(ExecutionContexts.sameThreadExecutionContext)
|
||||||
|
|
||||||
val nextTimer = Timer(key, msg, repeat, nextGen, task)
|
val nextTimer = Timer(key, msg, repeat, nextGen, task)
|
||||||
ctx.log.debug("Start timer [{}] with generation [{}]", key, nextGen)
|
|
||||||
timers = timers.updated(key, nextTimer)
|
timers = timers.updated(key, nextTimer)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -70,7 +70,6 @@ import akka.util.OptionVal
|
||||||
ctx.system.scheduler.scheduleOnce(timeout, ctx.self, timerMsg)(ctx.dispatcher)
|
ctx.system.scheduler.scheduleOnce(timeout, ctx.self, timerMsg)(ctx.dispatcher)
|
||||||
|
|
||||||
val nextTimer = Timer(key, msg, repeat, nextGen, task)
|
val nextTimer = Timer(key, msg, repeat, nextGen, task)
|
||||||
log.debug("Start timer [{}] with generation [{}]", key, nextGen)
|
|
||||||
timers = timers.updated(key, nextTimer)
|
timers = timers.updated(key, nextTimer)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue