no need to loadEnvelope of replayed

akka · Nov 29, 2024 · 362e543 · 362e543
1 parent 3e0425e
commit 362e543
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/...on-dynamodb/src/main/scala/akka/projection/dynamodb/internal/DynamoDBProjectionImpl.scala b/...on-dynamodb/src/main/scala/akka/projection/dynamodb/internal/DynamoDBProjectionImpl.scala
@@ -598,19 +598,17 @@ private[projection] object DynamoDBProjectionImpl {
                         import DynamoDBOffsetStore.Validation._
                         offsetStore
                           .validate(envelope)
-                          .flatMap {
+                          .map {
                             case Accepted =>
                               if (isFilteredEvent(envelope) && settings.warnAboutFilteredEventsInFlow) {
                                 log.info(
                                   "atLeastOnceFlow doesn't support skipping envelopes. Envelope [{}] still emitted.",
                                   envelope)
                               }
-                              loadEnvelope(envelope.asInstanceOf[Envelope], sourceProvider).map { loadedEnvelope =>
-                                offsetStore.addInflight(loadedEnvelope)
-                                Some(loadedEnvelope)
-                              }
+                              offsetStore.addInflight(envelope)
+                              Some(envelope.asInstanceOf[Envelope])
                             case Duplicate =>
-                              Future.successful(None)
+                              None
                             case RejectedSeqNr =>
                               // this shouldn't happen
                               throw new RejectedEnvelope(