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 27df715 use pekko trait CurrentLastSequenceNumberByPersistenceIdQuery
(#272)
27df715 is described below
commit 27df715eb38c0e794f17508969e23dc5c02f9bcd
Author: PJ Fanning <[email protected]>
AuthorDate: Fri Oct 24 17:42:48 2025 +0100
use pekko trait CurrentLastSequenceNumberByPersistenceIdQuery (#272)
* use pekko trait CurrentLastSequenceNumberByPersistenceIdQuery
* Update JdbcReadJournal.scala
* Update PekkoCoreDependency.scala
---
.../persistence/jdbc/query/javadsl/JdbcReadJournal.scala | 9 +++++----
.../persistence/jdbc/query/scaladsl/JdbcReadJournal.scala | 12 ++++++------
project/PekkoCoreDependency.scala | 2 +-
3 files changed, 12 insertions(+), 11 deletions(-)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/javadsl/JdbcReadJournal.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/javadsl/JdbcReadJournal.scala
index ad287bb..fea9dcc 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/javadsl/JdbcReadJournal.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/javadsl/JdbcReadJournal.scala
@@ -14,11 +14,10 @@
package org.apache.pekko.persistence.jdbc.query.javadsl
-import org.apache.pekko
-
import java.util.Optional
import java.util.concurrent.CompletionStage
+import org.apache.pekko
import pekko.NotUsed
import pekko.persistence.jdbc.query.scaladsl.{ JdbcReadJournal =>
ScalaJdbcReadJournal }
import pekko.persistence.query.{ EventEnvelope, Offset }
@@ -39,7 +38,8 @@ class JdbcReadJournal(journal: ScalaJdbcReadJournal)
with CurrentEventsByPersistenceIdQuery
with EventsByPersistenceIdQuery
with CurrentEventsByTagQuery
- with EventsByTagQuery {
+ with EventsByTagQuery
+ with CurrentLastSequenceNumberByPersistenceIdQuery {
/**
* Same type of query as `persistenceIds` but the event stream
@@ -146,7 +146,8 @@ class JdbcReadJournal(journal: ScalaJdbcReadJournal)
* @param persistenceId The `persistenceId` for which the last known
sequence number should be returned.
* @return Some sequence number or None if the `persistenceId` is unknown.
*/
- def currentLastSequenceNumberByPersistenceId(persistenceId: String):
CompletionStage[Optional[java.lang.Long]] =
+ override def currentLastSequenceNumberByPersistenceId(
+ persistenceId: String): CompletionStage[Optional[java.lang.Long]] =
journal
.currentLastSequenceNumberByPersistenceId(persistenceId)
.asJava
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 bf34df9..dd3054f 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
@@ -17,11 +17,13 @@ package scaladsl
import org.apache.pekko
import pekko.NotUsed
-import pekko.actor.ExtendedActorSystem
+import pekko.actor.{ ExtendedActorSystem, Scheduler }
import pekko.persistence.jdbc.config.ReadJournalConfig
import pekko.persistence.jdbc.query.JournalSequenceActor.{ GetMaxOrderingId,
MaxOrderingId }
import pekko.persistence.jdbc.db.SlickExtension
import pekko.persistence.jdbc.journal.dao.FlowControl
+import pekko.persistence.jdbc.query.dao.ReadJournalDao
+import pekko.persistence.jdbc.util.PluginVersionChecker
import pekko.persistence.query.scaladsl._
import pekko.persistence.query.{ EventEnvelope, Offset, Sequence }
import pekko.persistence.{ Persistence, PersistentRepr }
@@ -37,9 +39,6 @@ import scala.collection.immutable._
import scala.concurrent.duration._
import scala.concurrent.{ ExecutionContext, Future }
import scala.util.{ Failure, Success }
-import pekko.actor.Scheduler
-import pekko.persistence.jdbc.query.dao.ReadJournalDao
-import pekko.persistence.jdbc.util.PluginVersionChecker
object JdbcReadJournal {
final val Identifier = "jdbc-read-journal"
@@ -52,7 +51,8 @@ class JdbcReadJournal(config: Config, configPath:
String)(implicit val system: E
with CurrentEventsByPersistenceIdQuery
with EventsByPersistenceIdQuery
with CurrentEventsByTagQuery
- with EventsByTagQuery {
+ with EventsByTagQuery
+ with CurrentLastSequenceNumberByPersistenceIdQuery {
PluginVersionChecker.check()
@@ -324,6 +324,6 @@ class JdbcReadJournal(config: Config, configPath:
String)(implicit val system: E
* @param persistenceId The `persistenceId` for which the last known
sequence number should be returned.
* @return Some sequence number or None if the `persistenceId` is unknown.
*/
- def currentLastSequenceNumberByPersistenceId(persistenceId: String):
Future[Option[Long]] =
+ override def currentLastSequenceNumberByPersistenceId(persistenceId:
String): Future[Option[Long]] =
readJournalDao.lastPersistenceIdSequenceNumber(persistenceId)
}
diff --git a/project/PekkoCoreDependency.scala
b/project/PekkoCoreDependency.scala
index 992921f..1ad1bac 100644
--- a/project/PekkoCoreDependency.scala
+++ b/project/PekkoCoreDependency.scala
@@ -20,5 +20,5 @@ import com.github.pjfanning.pekkobuild.PekkoDependency
object PekkoCoreDependency extends PekkoDependency {
override val checkProject: String = "pekko-cluster-sharding-typed"
override val module: Option[String] = None
- override val currentVersion: String = "1.1.5"
+ override val currentVersion: String = "1.2.1"
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
