in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala [102:112]
override def receive: Receive = receive(0L, Map.empty, 0)
override def preStart(): Unit = {
self ! QueryState
stateStore.maxStateStoreOffset().mapTo[Long].onComplete {
case scala.util.Success(maxInDatabase) =>
self ! ScheduleAssumeMaxGlobalOffset(maxInDatabase)
case scala.util.Failure(t) =>
log.info("Failed to recover fast, using state-by-state recovery instead. Cause: {}", t)
}
}