From bb2b59d7c2594b701a0a4a18ba96400ad6f2293c Mon Sep 17 00:00:00 2001 From: Christopher Batey Date: Wed, 29 May 2019 15:21:16 +0100 Subject: [PATCH] Don't log internal messages as an event (#27014) * Don't log internal messages as an event --- .../akka/persistence/typed/internal/ReplayingEvents.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/ReplayingEvents.scala b/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/ReplayingEvents.scala index 84bcbd69d5..381dfdcdca 100644 --- a/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/ReplayingEvents.scala +++ b/akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/ReplayingEvents.scala @@ -190,12 +190,12 @@ private[akka] final class ReplayingEvents[C, E, S]( val sequenceNr = state.seqNr val msg = event match { + case Some(_: Message) | None => + s"Exception during recovery. Last known sequence number [$sequenceNr]. " + + s"PersistenceId [${setup.persistenceId.id}]. ${cause.getMessage}" case Some(evt) => s"Exception during recovery while handling [${evt.getClass.getName}] with sequence number [$sequenceNr]. " + s"PersistenceId [${setup.persistenceId.id}]. ${cause.getMessage}" - case None => - s"Exception during recovery. Last known sequence number [$sequenceNr]. " + - s"PersistenceId [${setup.persistenceId.id}]. ${cause.getMessage}" } throw new JournalFailureException(msg, cause)