From b3e06d2bed7233e41da24e8f91d328afbc8323cf Mon Sep 17 00:00:00 2001 From: Eugene Platonov Date: Thu, 2 Jan 2014 23:00:47 -0500 Subject: [PATCH] =act Normalize DeathWatch Debug events' messages --- akka-actor/src/main/scala/akka/actor/dungeon/DeathWatch.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-actor/src/main/scala/akka/actor/dungeon/DeathWatch.scala b/akka-actor/src/main/scala/akka/actor/dungeon/DeathWatch.scala index 56a541d3278..11628f2ca01 100644 --- a/akka-actor/src/main/scala/akka/actor/dungeon/DeathWatch.scala +++ b/akka-actor/src/main/scala/akka/actor/dungeon/DeathWatch.scala @@ -123,7 +123,7 @@ private[akka] trait DeathWatch { this: ActorCell ⇒ if (watcheeSelf && !watcherSelf) { if (!watchedBy.contains(watcher)) maintainAddressTerminatedSubscription(watcher) { watchedBy += watcher - if (system.settings.DebugLifecycle) publish(Debug(self.path.toString, clazz(actor), "now monitoring " + watcher)) + if (system.settings.DebugLifecycle) publish(Debug(self.path.toString, clazz(actor), s"now watched by $watcher")) } } else if (!watcheeSelf && watcherSelf) { watch(watchee) @@ -139,7 +139,7 @@ private[akka] trait DeathWatch { this: ActorCell ⇒ if (watcheeSelf && !watcherSelf) { if (watchedBy.contains(watcher)) maintainAddressTerminatedSubscription(watcher) { watchedBy -= watcher - if (system.settings.DebugLifecycle) publish(Debug(self.path.toString, clazz(actor), "stopped monitoring " + watcher)) + if (system.settings.DebugLifecycle) publish(Debug(self.path.toString, clazz(actor), s"no longer watched by $watcher")) } } else if (!watcheeSelf && watcherSelf) { unwatch(watchee)