From c1a95da8a70a483e929c503050ca54c1c742a49b Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Thu, 28 Nov 2024 16:20:08 +0100 Subject: [PATCH] 2 idleCountBeforeHeartbeat --- .../scala/akka/persistence/dynamodb/internal/BySliceQuery.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala b/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala index 1644c9f..de83618 100644 --- a/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala +++ b/core/src/main/scala/akka/persistence/dynamodb/internal/BySliceQuery.scala @@ -408,7 +408,7 @@ import org.slf4j.Logger } def heartbeat(state: QueryState): Option[Envelope] = { - if (state.idleCountBeforeHeartbeat >= 3 && state.previousQueryWallClock != Instant.EPOCH) { + if (state.idleCountBeforeHeartbeat >= 2 && state.previousQueryWallClock != Instant.EPOCH) { // use wall clock to measure duration since start, up to idle backtracking limit val timestamp = state.startTimestamp.plus( JDuration.between(state.startWallClock, state.previousQueryWallClock.minus(backtrackingBehindCurrentTime)))