From 8c8cdecc681bb72041cc15abbea97928f9069df7 Mon Sep 17 00:00:00 2001 From: Roland Date: Mon, 27 May 2013 20:27:56 +0200 Subject: [PATCH] do not close over context.self in TickGenerator, see #3393 --- akka-actor/src/main/scala/akka/io/Pipelines.scala | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/akka-actor/src/main/scala/akka/io/Pipelines.scala b/akka-actor/src/main/scala/akka/io/Pipelines.scala index 71f3f90417..7ec0a72db0 100644 --- a/akka-actor/src/main/scala/akka/io/Pipelines.scala +++ b/akka-actor/src/main/scala/akka/io/Pipelines.scala @@ -1197,10 +1197,13 @@ class TickGenerator[Cmd <: AnyRef, Evt <: AnyRef](interval: FiniteDuration) new PipePair[Cmd, Cmd, Evt, Evt] { // use unique object to avoid double-activation on actor restart - private val trigger: Trigger = + private val trigger: Trigger = { + val path = ctx.getContext.self.path + new Trigger { - override def toString = s"Tick[${ctx.getContext.self.path}]" + override def toString = s"Tick[$path]" } + } private def schedule() = ctx.getContext.system.scheduler.scheduleOnce(