Skip to content

Commit

Permalink
=act Normalize DeathWatch Debug events' messages
Browse files Browse the repository at this point in the history
  • Loading branch information
Eugene Platonov authored and Daniel Hobi committed Jan 23, 2014
1 parent a9d4923 commit b3e06d2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions akka-actor/src/main/scala/akka/actor/dungeon/DeathWatch.scala
Expand Up @@ -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)
Expand All @@ -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)
Expand Down

0 comments on commit b3e06d2

Please sign in to comment.