Return java.lang.Long value in javadsl.

apache · Feb 16, 2025 · 711145f · 711145f
1 parent 02197f8
commit 711145f
Showing 1 changed file with 2 additions and 2 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
@@ -145,9 +145,9 @@ 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 currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[Long]] =
+  def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[java.lang.Long]] =
     journal
       .currentLastKnownSequenceNumberByPersistenceId(persistenceId)
       .asJava
-      .thenApply(_.toJava)
+      .thenApply(_.map(java.lang.Long.valueOf).toJava)
 }