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 076534b issue with tick params in wrong order (#182) (#183)
076534b is described below
commit 076534bc8b94b8f328553770a1af80ac0f877c28
Author: PJ Fanning <[email protected]>
AuthorDate: Fri Apr 26 05:33:01 2024 +0200
issue with tick params in wrong order (#182) (#183)
---
.../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 d63b0d9..54e504b 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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
