From e9e65c463f89c26f3579abc2e72fd53172bc13f9 Mon Sep 17 00:00:00 2001
From: Patrik Nordwall <patrik.nordwall@gmail.com>
Date: Thu, 19 May 2016 21:12:47 +0200
Subject: [PATCH] improve restart logging

---
 .../src/main/scala/akka/remote/artery/Association.scala   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/akka-remote/src/main/scala/akka/remote/artery/Association.scala b/akka-remote/src/main/scala/akka/remote/artery/Association.scala
index cbc3abc118..7a3d8b2f66 100644
--- a/akka-remote/src/main/scala/akka/remote/artery/Association.scala
+++ b/akka-remote/src/main/scala/akka/remote/artery/Association.scala
@@ -265,16 +265,16 @@ private[akka] class Association(
       case _ if transport.isShutdown     ⇒ // don't restart after shutdown
       case _: AbruptTerminationException ⇒ // ActorSystem shutdown
       case cause: GaveUpSendingException ⇒
-        log.error(cause, "{} failed. Restarting it. {}", streamName, cause.getMessage)
+        log.debug("{} to {} failed. Restarting it. {}", streamName, remoteAddress, cause.getMessage)
         // restart unconditionally, without counting restarts
         restart(cause)
       case cause ⇒
         if (restartCounter.restart()) {
-          log.error(cause, "{} failed. Restarting it. {}", streamName, cause.getMessage)
+          log.error(cause, "{} to {} failed. Restarting it. {}", streamName, remoteAddress, cause.getMessage)
           restart(cause)
         } else {
-          log.error(cause, "{} failed and restarted {} times within {} seconds. Terminating system. {}",
-            streamName, maxRestarts, restartTimeout.toSeconds, cause.getMessage)
+          log.error(cause, s"{} to {} failed and restarted {} times within {} seconds. Terminating system. ${cause.getMessage}",
+            streamName, remoteAddress, maxRestarts, restartTimeout.toSeconds)
           transport.system.terminate()
         }
     }