ShoppingCartEntity with Akka Typed

shopping-cart-java-node0/shopping-cart/src/main/resources/application.conf

@@ -31,6 +31,8 @@ lagom.cluster.join-self = off
 remote.port=2552
 akka {
 
+  loglevel = DEBUG
+
   remote {
     log-remote-lifecycle-events = on
     netty.tcp {
@@ -60,4 +62,4 @@ akka {
     #
     # auto-down-unreachable-after = 10s
   }
-}
+}

shopping-cart-java-node0/shopping-cart/src/main/resources/logback.xml

@@ -0,0 +1,34 @@
+<configuration>
+
+    <conversionRule conversionWord="coloredLevel" converterClass="com.lightbend.lagom.internal.logback.ColoredLevel" />
+
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%date{"yyyy-MM-dd'T'HH:mm:ss.SSS'Z'",UTC} %coloredLevel %logger [%mdc] - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <appender name="ASYNCSTDOUT" class="ch.qos.logback.classic.AsyncAppender">
+        <appender-ref ref="STDOUT" />
+    </appender>
+
+    <!-- Set logging for all Play library classes -->
+    <logger name="play" level="INFO" />
+    <!-- Set logging for all Akka library classes -->
+    <logger name="akka" level="INFO" />
+    <logger name="akka.actor.TimerScheduler" level="INFO" />
+    <logger name="akka.cluster.ddata.Replicator" level="INFO" />
+    <!-- Set logging for all Lagom library classes -->
+    <logger name="com.lightbend.lagom" level="INFO" />
+
+    <!-- Cassandra and the datasta driver are used by the Lagom event sourcing modules -->
+    <logger name="org.apache.cassandra" level="ERROR" />
+    <logger name="com.datastax.driver" level="ERROR" />
+    <!-- Turn down Kafka noise -->
+    <logger name="org.apache.kafka" level="WARN" />
+
+    <root level="INFO">
+        <appender-ref ref="ASYNCSTDOUT" />
+    </root>
+
+</configuration>

shopping-cart-java-node1/build.sbt

@@ -10,27 +10,30 @@ version in ThisBuild ~= (_.replace('+', '-'))
 dynver in ThisBuild ~= (_.replace('+', '-'))
 
 val hibernateEntityManager = "org.hibernate" % "hibernate-entitymanager" % "5.4.2.Final"
-val jpaApi  = "org.hibernate.javax.persistence" % "hibernate-jpa-2.1-api" % "1.0.0.Final"
+val jpaApi = "org.hibernate.javax.persistence" % "hibernate-jpa-2.1-api" % "1.0.0.Final"
 val validationApi = "javax.validation" % "validation-api" % "1.1.0.Final"
 
+val akkaVersion = "2.6.0-M3"
+
 lazy val `shopping-cart-java` = (project in file("."))
   .aggregate(`shopping-cart-api`, `shopping-cart`)
 
 lazy val `shopping-cart-api` = (project in file("shopping-cart-api"))
   .settings(common)
-  .settings(
-    libraryDependencies ++= Seq(
-      lagomJavadslApi,
-      lombok
-    )
-  )
+  .settings(libraryDependencies ++= Seq(lagomJavadslApi, lombok))
 
 lazy val `shopping-cart` = (project in file("shopping-cart"))
   .enablePlugins(LagomJava)
   .settings(common)
   .settings(dockerSettings)
   .settings(
     libraryDependencies ++= Seq(
+      "com.typesafe.akka" %% "akka-actor-typed" % akkaVersion,
+      "com.typesafe.akka" %% "akka-cluster-typed" % akkaVersion,
+      "com.typesafe.akka" %% "akka-cluster-sharding-typed" % akkaVersion,
+      "com.typesafe.akka" %% "akka-persistence-typed" % akkaVersion,
+      // Netty needed for Akka classic remoting
+      "io.netty" % "netty" % "3.10.6.Final",
       lagomJavadslPersistenceJdbc,
       lagomJavadslPersistenceJpa,
       lagomLogback,
@@ -58,7 +61,12 @@ val akkaDiscoveryKubernetesApi = "com.lightbend.akka.discovery" %% "akka-discove
 val lagomJavadslAkkaDiscovery = "com.lightbend.lagom" %% "lagom-javadsl-akka-discovery-service-locator" % LagomVersion.current
 
 def common = Seq(
-  javacOptions in (Compile,compile) ++= Seq("-Xlint:unchecked", "-Xlint:deprecation", "-parameters", "-Werror")
+  javacOptions in (Compile, compile) ++= Seq(
+    "-Xlint:unchecked",
+    "-Xlint:deprecation",
+    "-parameters",
+    "-Werror"
+  )
 )
 
 def dockerSettings = Seq(

shopping-cart-java-node1/shopping-cart/src/main/java/com/example/shoppingcart/impl/ShoppingCartCommand.java

@@ -1,11 +1,10 @@
 package com.example.shoppingcart.impl;
 
-import akka.Done;
-import com.example.shoppingcart.api.ShoppingCart;
+import akka.actor.typed.ActorRef;
+import akka.persistence.typed.ExpectingReply;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import com.google.common.base.Preconditions;
-import com.lightbend.lagom.javadsl.persistence.PersistentEntity;
 import com.lightbend.lagom.serialization.CompressedJsonable;
 import com.lightbend.lagom.serialization.Jsonable;
 import lombok.Value;
@@ -17,24 +16,31 @@
  * makes it simple to get a complete picture of what commands an entity
  * supports.
  */
-public interface ShoppingCartCommand extends Jsonable {
+public interface ShoppingCartCommand<ReplyType> extends Jsonable, ExpectingReply<ReplyType> {
     /**
      * A command to update an item.
      *
-     * It has a reply type of {@link akka.Done}, which is sent back to the caller
+     * It has a reply type of {@link OperationResult}, which is sent back to the caller
      * when all the events emitted by this command are successfully persisted.
      */
     @SuppressWarnings("serial")
     @Value
     @JsonDeserialize
-    final class UpdateItem implements ShoppingCartCommand, CompressedJsonable, PersistentEntity.ReplyType<Done> {
+    final class UpdateItem implements ShoppingCartCommand<OperationResult>, CompressedJsonable {
         public final String productId;
         public final int quantity;
+        private final ActorRef<OperationResult> replyTo;
 
         @JsonCreator
-        UpdateItem(String productId, int quantity) {
+        UpdateItem(String productId, int quantity, ActorRef<OperationResult> replyTo) {
             this.productId = Preconditions.checkNotNull(productId, "productId");
             this.quantity = quantity;
+            this.replyTo = replyTo;
+        }
+
+        @Override
+        public ActorRef<OperationResult> replyTo() {
+            return replyTo;
         }
     }
 
@@ -43,17 +49,50 @@ final class UpdateItem implements ShoppingCartCommand, CompressedJsonable, Persi
      *
      * The reply type is the {@link ShoppingCartState}
      */
-    enum Get implements ShoppingCartCommand, PersistentEntity.ReplyType<ShoppingCartState> {
-        INSTANCE
+    final class Get implements ShoppingCartCommand<ShoppingCartState> {
+        private final ActorRef<ShoppingCartState> replyTo;
+
+        @JsonCreator
+        public Get(ActorRef<ShoppingCartState> replyTo) {
+            this.replyTo = replyTo;
+        }
+
+        @Override
+        public ActorRef<ShoppingCartState> replyTo() {
+            return replyTo;
+        }
     }
 
     /**
      * A command to checkout the shopping cart.
      *
-     * The reply type is the Done, which will be returned when the events have been
+     * The reply type is the {@link OperationResult}, which will be returned when the events have been
      * emitted.
      */
-    enum Checkout implements ShoppingCartCommand, PersistentEntity.ReplyType<Done> {
+    class Checkout implements ShoppingCartCommand<OperationResult> {
+        private final ActorRef<OperationResult> replyTo;
+
+        public Checkout(ActorRef<OperationResult> replyTo) {
+            this.replyTo = replyTo;
+        }
+
+        @Override
+        public ActorRef<OperationResult> replyTo() {
+            return replyTo;
+        }
+    }
+
+    interface OperationResult {}
+
+    enum Confirmed implements OperationResult {
         INSTANCE
     }
+
+    class Rejected implements OperationResult {
+        public final String reason;
+
+        public Rejected(String reason) {
+            this.reason = reason;
+        }
+    }
 }