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

Don't log internal messages as an event (#27014)

Browse source 
* Don't log internal messages as an event
This commit is contained in:
Christopher Batey 2019-05-29 15:21:16 +01:00 • committed by GitHub
parent 6754bf7f73
commit bb2b59d7c2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/ReplayingEvents.scala
View file

@ -190,12 +190,12 @@ private[akka] final class ReplayingEvents[C, E, S](
val sequenceNr = state.seqNr val sequenceNr = state.seqNr
val msg = event match { 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) => case Some(evt) =>
s"Exception during recovery while handling [${evt.getClass.getName}] with sequence number [$sequenceNr]. " + s"Exception during recovery while handling [${evt.getClass.getName}] with sequence number [$sequenceNr]. " +
s"PersistenceId [${setup.persistenceId.id}]. ${cause.getMessage}" 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) throw new JournalFailureException(msg, cause)