You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by md...@apache.org on 2025/12/11 00:17:01 UTC
(pekko-persistence-jdbc) branch main updated: Use OptionalUtil to convert Java Optional
This is an automated email from the ASF dual-hosted git repository.
mdedetrich 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 7a36bda Use OptionalUtil to convert Java Optional
7a36bda is described below
commit 7a36bda7d0dd1079dcf1105a90b95abab33e70a9
Author: Matthew de Detrich <md...@gmail.com>
AuthorDate: Thu Dec 11 11:09:37 2025 +1100
Use OptionalUtil to convert Java Optional
---
.../pekko/persistence/jdbc/state/javadsl/JdbcDurableStateStore.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/javadsl/JdbcDurableStateStore.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/javadsl/JdbcDurableStateStore.scala
index cc03995..55dea74 100644
--- a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/javadsl/JdbcDurableStateStore.scala
+++ b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/javadsl/JdbcDurableStateStore.scala
@@ -14,7 +14,6 @@
package org.apache.pekko.persistence.jdbc.state.javadsl
-import java.util.Optional
import java.util.concurrent.CompletionStage
import org.apache.pekko
@@ -27,6 +26,7 @@ import pekko.persistence.query.{ DurableStateChange, Offset }
import pekko.persistence.query.javadsl.DurableStateStoreQuery
import pekko.persistence.state.javadsl.{ DurableStateUpdateStore, GetObjectResult }
import pekko.stream.javadsl.Source
+import pekko.util.OptionalUtil
import slick.jdbc.JdbcProfile
import scala.concurrent.ExecutionContext
@@ -52,7 +52,7 @@ class JdbcDurableStateStore[A](
def getObject(persistenceId: String): CompletionStage[GetObjectResult[A]] =
scalaStore
.getObject(persistenceId)
- .map(x => GetObjectResult(Optional.ofNullable(x.value.getOrElse(null.asInstanceOf[A])), x.revision)).asJava
+ .map(x => GetObjectResult(OptionalUtil.convertOption(x.value), x.revision)).asJava
def upsertObject(persistenceId: String, revision: Long, value: A, tag: String): CompletionStage[Done] =
scalaStore.upsertObject(persistenceId, revision, value, tag).asJava
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org