build: Akka 2.9.3 bump, Akka Paradox Theme bump, 5.4.1 license change…

… date (#834)
akka · May 8, 2024 · 97b7924 · 97b7924
1 parent 646c051
commit 97b7924
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 8 deletions.
diff --git a/LICENSE b/LICENSE
@@ -3,7 +3,7 @@ Business Source License 1.1
 Parameters
 
 Licensor:             Lightbend, Inc.
-Licensed Work:        Akka Persistence JDBC 5.4.0
+Licensed Work:        Akka Persistence JDBC 5.4.1
                       This license applies to all sub directories and files
                       UNLESS another license file is present in a sub
                       directory, then that other license applies to all files
@@ -19,7 +19,7 @@ Additional Use Grant:
     Connecting to a Play Framework websocket and/or Play Framework
     request/response bodies for server and play-ws client.
 
-Change Date:          2027-03-21
+Change Date:          2027-05-08
 
 Change License:       Apache License, Version 2.0
 

diff --git a/core/src/main/scala/akka/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala b/core/src/main/scala/akka/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
@@ -83,8 +83,6 @@ class JdbcReadJournal(config: Config, configPath: String)(implicit val system: E
   private[query] lazy val journalSequenceActor = system.systemActorOf(
     JournalSequenceActor.props(readJournalDao, readJournalConfig.journalSequenceRetrievalConfiguration),
     s"$configPath.akka-persistence-jdbc-journal-sequence-actor")
-  private val delaySource =
-    Source.tick(readJournalConfig.refreshInterval, 0.seconds, 0).take(1)
 
   /**
    * Same type of query as `persistenceIds` but the event stream
@@ -108,8 +106,9 @@ class JdbcReadJournal(config: Config, configPath: String)(implicit val system: E
    */
   override def persistenceIds(): Source[String, NotUsed] =
     Source
-      .repeat(0)
-      .flatMapConcat(_ => delaySource.flatMapConcat(_ => currentPersistenceIds()))
+      .single(0)
+      .concat(Source.tick(readJournalConfig.refreshInterval, readJournalConfig.refreshInterval, 0))
+      .flatMapConcat(_ => currentPersistenceIds())
       .statefulMapConcat[String] { () =>
         var knownIds = Set.empty[String]
         def next(id: String): Iterable[String] = {

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -7,7 +7,7 @@ object Dependencies {
 
   val ScalaVersions = Seq(Scala213, Scala3)
 
-  val AkkaVersion = "2.9.0"
+  val AkkaVersion = "2.9.3"
   val AkkaBinaryVersion = AkkaVersion.take(3)
 
   val SlickVersion = "3.5.1"

diff --git a/project/plugins.sbt b/project/plugins.sbt
@@ -11,7 +11,7 @@ addDependencyTreePlugin
 addSbtPlugin("com.github.sbt" % "sbt-ci-release" % "1.5.12")
 addSbtPlugin("com.github.sbt" % "sbt-dynver" % "5.0.1")
 // docs
-addSbtPlugin("com.lightbend.akka" % "sbt-paradox-akka" % "0.55")
+addSbtPlugin("com.lightbend.akka" % "sbt-paradox-akka" % "0.57")
 addSbtPlugin("com.github.sbt" % "sbt-site" % "1.7.0")
 addSbtPlugin("com.github.sbt" % "sbt-site-paradox" % "1.7.0")
 addSbtPlugin("com.github.sbt" % "sbt-unidoc" % "0.5.0")