This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 3ee66be issue with tick params in wrong order (#182)
3ee66be is described below
commit 3ee66be642906784fc7e673eff56bab3dc756fe1
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Apr 25 21:14:19 2024 +0200
issue with tick params in wrong order (#182)
---
.../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]
