From 799b41764a6de7eb7cd88a628aa6bf8f44d2168f Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Thu, 25 Apr 2024 20:51:24 +0200 Subject: [PATCH] issue with tick params in wrong order --- .../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 d63b0d90..54e504b2 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(readJournalConfig.refreshInterval, 0.seconds, 0).take(1) + Source.tick(0.seconds, readJournalConfig.refreshInterval, 0).take(1) /** * Same type of query as `persistenceIds` but the event stream