chore: Use public api for exp backoff delay

akka · Nov 22, 2024 · d3d974d · d3d974d
1 parent d3ad158
commit d3d974d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...projection-dynamodb/src/main/scala/akka/projection/dynamodb/internal/OffsetStoreDao.scala b/...projection-dynamodb/src/main/scala/akka/projection/dynamodb/internal/OffsetStoreDao.scala
@@ -17,7 +17,7 @@ import scala.jdk.FutureConverters._
 import akka.Done
 import akka.actor.typed.ActorSystem
 import akka.annotation.InternalApi
-import akka.pattern.BackoffSupervisor
+import akka.pattern.RetrySupport
 import akka.pattern.after
 import akka.persistence.dynamodb.internal.InstantFactory
 import akka.persistence.query.TimestampOffset
@@ -131,7 +131,7 @@ import software.amazon.awssdk.services.dynamodb.model.BatchWriteItemResponse
           val unprocessed = response.unprocessedItems
           val newReq = batchReq.toBuilder.requestItems(unprocessed).build()
           val nextRetry = retries + 1
-          val delay = BackoffSupervisor.calculateDelay(
+          val delay = RetrySupport.calculateExponentialBackoffDelay(
             retries,
             settings.retrySettings.minBackoff,
             settings.retrySettings.maxBackoff,