= actor add clarify message to dead letter listener

This commit is contained in:
虎鸣 2018-04-21 05:32:18 +08:00
parent 414be2c0cb
commit 8736d2a407

View file

@ -34,6 +34,7 @@ class DeadLetterListener extends Actor {
val doneMsg = if (done) ", no more dead letters will be logged" else ""
eventStream.publish(Info(rcp.path.toString, rcp.getClass,
s"Message [${message.getClass.getName}] $origin to $rcp was not delivered. [$count] dead letters encountered$doneMsg. " +
s"If this is not an expected behavior, then [$rcp] may terminated unexpectedly, " +
"This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' " +
"and 'akka.log-dead-letters-during-shutdown'."))
if (done) context.stop(self)