raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

improve restart logging

Browse source
This commit is contained in:
Patrik Nordwall 2016-05-19 21:12:47 +02:00
parent c90121485f
commit e9e65c463f
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-remote/src/main/scala/akka/remote/artery/Association.scala
View file

@ -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()
}
}