This is an automated email from the ASF dual-hosted git repository.
roiocam pushed a commit to branch 1.0.x
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/1.0.x by this push:
new a403be5 fix: flaky H2ScalaAllPersistenceIdsTest (#199) (#200)
a403be5 is described below
commit a403be5fa77fa24de92d5dd5744b8c16d0b0e720
Author: AndyChen(Jingzhang) <[email protected]>
AuthorDate: Fri May 31 08:47:22 2024 +0800
fix: flaky H2ScalaAllPersistenceIdsTest (#199) (#200)
---
.../apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
index 54e504b..352721d 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
@@ -94,7 +94,7 @@ class JdbcReadJournal(config: Config, configPath:
String)(implicit val system: E
JournalSequenceActor.props(readJournalDao,
readJournalConfig.journalSequenceRetrievalConfiguration),
s"$configPath.pekko-persistence-jdbc-journal-sequence-actor")
private val delaySource =
- Source.tick(0.seconds, readJournalConfig.refreshInterval, 0).take(1)
+ Source.tick(0.seconds, readJournalConfig.refreshInterval, 0)
/**
* Same type of query as `persistenceIds` but the event stream
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
