fix: giving more gap of event

akka · Nov 2, 2023 · 7361d0a · 7361d0a
1 parent 9c7abe4
commit 7361d0a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala b/core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala
@@ -173,7 +173,7 @@ abstract class CurrentEventsByTagTest(config: String) extends QueryTestSpec(conf
       val latch = new CountDownLatch(1)
       val largeNumberOfMessage = 2000
       val smallNumberOfMessage = 200
-      val diff = largeNumberOfMessage - smallNumberOfMessage
+      val diff = largeNumberOfMessage - (smallNumberOfMessage * 3)
       val journalOps = new JavaDslJdbcReadJournalOperations(system)
       import system.dispatcher
       withTestActors(replyToMessages = true) { (actor1, actor2, actor3) =>