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

use internalLogger instead of context.log for recovery logging (#30563)

Browse source
This commit is contained in:
Andreas Gabor 2021-08-24 14:33:53 +02:00 • committed by GitHub
parent 8ad0b992d6
commit 418132b5fe
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/ReplayingSnapshot.scala
View file

@ -151,7 +151,7 @@ private[akka] class ReplayingSnapshot[C, E, S](override val setup: BehaviorSetup
val (seqNr: Long, seenPerReplica, version) = snapshot match {
case Some(SelectedSnapshot(metadata, snapshot)) =>
state = setup.snapshotAdapter.fromJournal(snapshot)
setup.context.log.debug("Loaded snapshot with metadata [{}]", metadata)
setup.internalLogger.debug("Loaded snapshot with metadata [{}]", metadata)
metadata.metadata match {
case Some(rm: ReplicatedSnapshotMetadata) => (metadata.sequenceNr, rm.seenPerReplica, rm.version)
case _ => (metadata.sequenceNr, Map.empty[ReplicaId, Long].withDefaultValue(0L), VersionVector.empty)
@ -159,7 +159,7 @@ private[akka] class ReplayingSnapshot[C, E, S](override val setup: BehaviorSetup
case None => (0L, Map.empty[ReplicaId, Long].withDefaultValue(0L), VersionVector.empty)
}
setup.context.log.debugN("Snapshot recovered from {} {} {}", seqNr, seenPerReplica, version)
setup.internalLogger.debugN("Snapshot recovered from {} {} {}", seqNr, seenPerReplica, version)
setup.cancelRecoveryTimer()

2
akka-persistence-typed/src/main/scala/akka/persistence/typed/state/internal/Recovering.scala
View file

@ -144,7 +144,7 @@ private[akka] class Recovering[C, S](override val setup: BehaviorSetup[C, S])
case None => setup.emptyState
}
setup.context.log.debug("Recovered from revision [{}]", result.revision)
setup.internalLogger.debug("Recovered from revision [{}]", result.revision)
setup.cancelRecoveryTimer()