From bc09e610f62e4e230fe8d73fa663f02a1dc9e4dd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Johan=20Andr=C3=A9n?= <johan@markatta.com>
Date: Mon, 29 Aug 2016 14:20:48 +0200
Subject: [PATCH] =per Log more info when recovery fails #20728 (#21313)

---
 .../persistence/PersistentActorRecoveryTimeoutSpec.scala     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/akka-persistence/src/test/scala/akka/persistence/PersistentActorRecoveryTimeoutSpec.scala b/akka-persistence/src/test/scala/akka/persistence/PersistentActorRecoveryTimeoutSpec.scala
index c4443831ad..2bb291a65f 100644
--- a/akka-persistence/src/test/scala/akka/persistence/PersistentActorRecoveryTimeoutSpec.scala
+++ b/akka-persistence/src/test/scala/akka/persistence/PersistentActorRecoveryTimeoutSpec.scala
@@ -1,7 +1,7 @@
 package akka.persistence
 
 import akka.actor.Status.Failure
-import akka.actor.{ Actor, ActorRef, Props }
+import akka.actor.{ Actor, ActorLogging, ActorRef, Props }
 import akka.persistence.journal.SteppingInmemJournal
 import akka.testkit.{ AkkaSpec, ImplicitSender, TestProbe }
 import com.typesafe.config.ConfigFactory
@@ -32,7 +32,7 @@ object PersistentActorRecoveryTimeoutSpec {
     }
   }
 
-  class TestReceiveTimeoutActor(receiveTimeout: FiniteDuration, probe: ActorRef) extends NamedPersistentActor("recovery-timeout-actor-2") {
+  class TestReceiveTimeoutActor(receiveTimeout: FiniteDuration, probe: ActorRef) extends NamedPersistentActor("recovery-timeout-actor-2") with ActorLogging {
 
     override def preStart(): Unit = {
       context.setReceiveTimeout(receiveTimeout)
@@ -50,6 +50,7 @@ object PersistentActorRecoveryTimeoutSpec {
     }
 
     override protected def onRecoveryFailure(cause: Throwable, event: Option[Any]): Unit = {
+      log.error(cause, "Recovery of TestReceiveTimeoutActor failed")
       probe ! Failure(cause)
     }
   }