Skip to content

Commit 9e1d2a0

Browse files
author
Taichi Yamakawa
committed
Execute fetchEntityEventsResponseMapper once
1 parent 2a2f8ed commit 9e1d2a0

File tree

1 file changed

+4
-2
lines changed
  • src/main/scala/lerna/akka/entityreplication/typed/internal/behavior

1 file changed

+4
-2
lines changed

src/main/scala/lerna/akka/entityreplication/typed/internal/behavior/Recovering.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,22 +89,24 @@ private[entityreplication] class Recovering[Command, Event, State](
8989
case Some(snapshot) => snapshot.metadata.logEntryIndex
9090
case None => LogEntryIndex.initial()
9191
}
92+
val replyTo =
93+
fetchEntityEventsResponseMapper(command.entitySnapshot)
9294
if (context.log.isTraceEnabled) {
9395
context.log.trace(
9496
"[{}] Sending FetchEntityEvents: entityId=[{}], fromIndex=[{}], toIndex=[{}], replyTo=[{}], to=[{}]",
9597
stateName,
9698
setup.replicationId.entityId.raw,
9799
snapshotIndex.next(),
98100
recoveryIndex,
99-
fetchEntityEventsResponseMapper(command.entitySnapshot),
101+
replyTo,
100102
setup.shard,
101103
)
102104
}
103105
setup.shard ! FetchEntityEvents(
104106
setup.replicationId.entityId,
105107
from = snapshotIndex.next(),
106108
to = recoveryIndex,
107-
fetchEntityEventsResponseMapper(command.entitySnapshot),
109+
replyTo,
108110
)
109111
Behaviors.same
110112
case command: RaftProtocol.RecoveryState =>

0 commit comments

Comments
 (0)