Java should be working now (but isn't replicating back to cloud)

akka · Dec 8, 2023 · 66b3b9c · 66b3b9c
1 parent ad1867b
commit 66b3b9c
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 10 deletions.
diff --git a/samples/grpc/local-drone-control-java/pom.xml b/samples/grpc/local-drone-control-java/pom.xml
@@ -18,7 +18,7 @@
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <akka.version>2.9.1-M1</akka.version>
-        <akka-projection.version>1.5.1-M1-10-16681325-SNAPSHOT</akka-projection.version>
+        <akka-projection.version>1.5.1-M1-16-e358cac2-SNAPSHOT</akka-projection.version>
         <akka-persistence-r2dbc.version>1.2.0</akka-persistence-r2dbc.version>
         <akka-management.version>1.5.0</akka-management.version>
         <akka-diagnostics.version>2.1.0</akka-diagnostics.version>

diff --git a/samples/grpc/local-drone-control-java/src/main/java/charging/ChargingStation.java b/samples/grpc/local-drone-control-java/src/main/java/charging/ChargingStation.java
@@ -158,8 +158,13 @@ public static Behavior<Command> create(
             Behaviors.withTimers(
                 (TimerScheduler<Command> timers) ->
                     replicatedBehaviors.setup(
-                        replicationContext ->
-                            new ChargingStation(context, replicationContext, timers))));
+                        replicationContext -> {
+                          context
+                              .getLog()
+                              .info(
+                                  "Charging Station {} starting up", replicationContext.entityId());
+                          return new ChargingStation(context, replicationContext, timers);
+                        })));
   }
 
   private static Duration durationUntil(Instant instant) {

diff --git a/samples/grpc/local-drone-control-java/src/main/resources/grpc.conf b/samples/grpc/local-drone-control-java/src/main/resources/grpc.conf
@@ -31,3 +31,9 @@ akka.projection.grpc.consumer {
   }
   stream-id = "delivery-events"
 }
+
+akka.projection.grpc {
+  producer {
+    query-plugin-id = "akka.persistence.r2dbc.query"
+  }
+}
diff --git a/samples/grpc/restaurant-drone-deliveries-service-java/pom.xml b/samples/grpc/restaurant-drone-deliveries-service-java/pom.xml
@@ -18,7 +18,7 @@
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <akka.version>2.9.1-M1</akka.version>
-        <akka-projection.version>1.5.1-M1-10-16681325-SNAPSHOT</akka-projection.version>
+        <akka-projection.version>1.5.1-M1-16-e358cac2-SNAPSHOT</akka-projection.version>
         <akka-persistence-r2dbc.version>1.2.0</akka-persistence-r2dbc.version>
         <akka-management.version>1.5.0</akka-management.version>
         <akka-diagnostics.version>2.1.0</akka-diagnostics.version>

diff --git a/...grpc/restaurant-drone-deliveries-service-java/src/main/java/charging/ChargingStation.java b/...grpc/restaurant-drone-deliveries-service-java/src/main/java/charging/ChargingStation.java
@@ -154,12 +154,12 @@ public static Behavior<Command> create(
                 (TimerScheduler<Command> timers) ->
                     replicatedBehaviors.setup(
                         replicationContext -> {
-                          context.getLog().info(
-                              "Charging Station {} starting up",
-                              replicationContext.entityId());
-                          return new ChargingStation(context, replicationContext, timers)
-                        })
-                ));
+                          context
+                              .getLog()
+                              .info(
+                                  "Charging Station {} starting up", replicationContext.entityId());
+                          return new ChargingStation(context, replicationContext, timers);
+                        })));
   }
 
   private static Duration durationUntil(Instant instant) {