Skip to content

Commit 3d9afbb

Browse files
committed
better logging of replicated event
1 parent c9cfe0a commit 3d9afbb

File tree

1 file changed

+5
-3
lines changed
  • akka-persistence-typed/src/main/scala/akka/persistence/typed/internal

1 file changed

+5
-3
lines changed

akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -501,12 +501,14 @@ private[akka] object Running {
501501

502502
if (setup.internalLogger.isDebugEnabled())
503503
setup.internalLogger.debug(
504-
"Processing event [{}] with version [{}]. Local version: {}. Updated version {}. Concurrent? {}",
504+
"Processing replicated event [{}], origin [{}], origin seqNr [{}], concurrent [{}], with version [{}]. Local version: {}. Updated version {}.",
505505
Logging.simpleName(event.event.getClass),
506+
event.originReplica,
507+
event.originSequenceNr,
508+
isConcurrent,
506509
event.originVersion,
507510
state.version,
508-
updatedVersion,
509-
isConcurrent)
511+
updatedVersion)
510512

511513
replication.setContext(recoveryRunning = false, event.originReplica, concurrent = isConcurrent)
512514

0 commit comments

Comments
 (0)