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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
