test: Harden DynamoDBTimestampOffsetProjectionSpec (#1264)

* failing test: "store offset for failing events when using RecoveryStrategy.skip" * projection might have been stopped before the error occured
akka · Nov 22, 2024 · d5433ff · d5433ff
1 parent 1751e82
commit d5433ff
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git a/...ation/src/test/scala/akka/projection/dynamodb/DynamoDBTimestampOffsetProjectionSpec.scala b/...ation/src/test/scala/akka/projection/dynamodb/DynamoDBTimestampOffsetProjectionSpec.scala
@@ -921,6 +921,7 @@ class DynamoDBTimestampOffsetProjectionSpec
       offsetShouldBeEmpty()
       projectionTestKit.run(projectionFailing) {
         projectedTestValueShouldBe("e1|e2|e3|e4|e5")
+        bogusEventHandler.attempts shouldBe 1
       }
       eventually {
         latestOffsetShouldBe(envelopes.last.offset)

diff --git a/...-projection-jdbc-integration/src/test/scala/akka/projection/jdbc/JdbcProjectionSpec.scala b/...-projection-jdbc-integration/src/test/scala/akka/projection/jdbc/JdbcProjectionSpec.scala
@@ -360,6 +360,7 @@ class JdbcProjectionSpec
       offsetShouldBeEmpty()
       projectionTestKit.run(projectionFailing) {
         projectedValueShouldBe("e1|e2|e3|e4|e5")
+        bogusEventHandler.attempts shouldBe 1
       }
       eventually {
         offsetShouldBe(6L)

diff --git a/...ojection-r2dbc-integration/src/test/scala/akka/projection/r2dbc/R2dbcProjectionSpec.scala b/...ojection-r2dbc-integration/src/test/scala/akka/projection/r2dbc/R2dbcProjectionSpec.scala
@@ -363,6 +363,7 @@ class R2dbcProjectionSpec
       offsetShouldBeEmpty()
       projectionTestKit.run(projectionFailing) {
         projectedValueShouldBe("e1|e2|e3|e4|e5")
+        bogusEventHandler.attempts shouldBe 1
       }
       eventually {
         offsetShouldBe(6L)

diff --git a/...integration/src/test/scala/akka/projection/r2dbc/R2dbcTimestampOffsetProjectionSpec.scala b/...integration/src/test/scala/akka/projection/r2dbc/R2dbcTimestampOffsetProjectionSpec.scala
@@ -418,6 +418,7 @@ class R2dbcTimestampOffsetProjectionSpec
       offsetShouldBeEmpty()
       projectionTestKit.run(projectionFailing) {
         projectedValueShouldBe("e1|e2|e3|e4|e5")
+        bogusEventHandler.attempts shouldBe 1
       }
       eventually {
         offsetShouldBe(envelopes.last.offset)