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

=per Log more info when recovery fails #20728 (#21313)

Browse source
This commit is contained in:
Johan Andrén 2016-08-29 14:20:48 +02:00 • committed by Konrad Malawski
parent 324a40ba97
commit bc09e610f6
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-persistence/src/test/scala/akka/persistence/PersistentActorRecoveryTimeoutSpec.scala
View file

@ -1,7 +1,7 @@
package akka.persistence package akka.persistence
import akka.actor.Status.Failure 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.persistence.journal.SteppingInmemJournal
import akka.testkit.{ AkkaSpec, ImplicitSender, TestProbe } import akka.testkit.{ AkkaSpec, ImplicitSender, TestProbe }
import com.typesafe.config.ConfigFactory 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 = { override def preStart(): Unit = {
context.setReceiveTimeout(receiveTimeout) context.setReceiveTimeout(receiveTimeout)
@ -50,6 +50,7 @@ object PersistentActorRecoveryTimeoutSpec {
} }
override protected def onRecoveryFailure(cause: Throwable, event: Option[Any]): Unit = { override protected def onRecoveryFailure(cause: Throwable, event: Option[Any]): Unit = {
log.error(cause, "Recovery of TestReceiveTimeoutActor failed")
probe ! Failure(cause) probe ! Failure(cause)
} }
} }