setting keyValue flag for ESE and KVE

akka · Jan 9, 2025 · e0d7804 · e0d7804
1 parent be27f44
commit e0d7804
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/akka-javasdk/src/main/scala/akka/javasdk/impl/SdkRunner.scala b/akka-javasdk/src/main/scala/akka/javasdk/impl/SdkRunner.scala
@@ -450,7 +450,12 @@ private final class Sdk(
               })
         }
         eventSourcedEntityDescriptors :+=
-          new EventSourcedEntityDescriptor(componentId, clz.getName, readOnlyCommandNames, instanceFactory)
+          new EventSourcedEntityDescriptor(
+            componentId,
+            clz.getName,
+            readOnlyCommandNames,
+            instanceFactory,
+            keyValue = false)
 
       case clz if classOf[KeyValueEntity[_]].isAssignableFrom(clz) =>
         val componentId = clz.getAnnotation(classOf[ComponentId]).value
@@ -475,7 +480,12 @@ private final class Sdk(
               })
         }
         keyValueEntityDescriptors :+=
-          new EventSourcedEntityDescriptor(componentId, clz.getName, readOnlyCommandNames, instanceFactory)
+          new EventSourcedEntityDescriptor(
+            componentId,
+            clz.getName,
+            readOnlyCommandNames,
+            instanceFactory,
+            keyValue = true)
 
       case clz if Reflect.isWorkflow(clz) =>
         val componentId = clz.getAnnotation(classOf[ComponentId]).value