chore: Missing applyWithProducerFilter in sample (#1068)

akka · Nov 13, 2023 · b6114db · b6114db
1 parent 28ff30d
commit b6114db
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/samples/replicated/shopping-cart-service-java/src/main/java/shopping/cart/ShoppingCart.java b/samples/replicated/shopping-cart-service-java/src/main/java/shopping/cart/ShoppingCart.java
@@ -338,7 +338,7 @@ public static Replication<Command> initWithProducerFilter(ActorSystem<?> system)
       return envelope.getTags().contains(VIP_CUSTOMER_TAG);
     };
 
-    return Replication.grpcReplication(replicationSettings, producerFilter,  ShoppingCart::create, system);
+    return Replication.grpcReplication(replicationSettings, producerFilter,  ShoppingCart::createWithProducerFilter, system);
   }
 
   public static Behavior<Command> createWithProducerFilter(

diff --git a/...es/replicated/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala b/...es/replicated/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala
@@ -201,7 +201,7 @@ object ShoppingCart {
       envelope.tags.contains(VipCustomerTag)
     }
 
-    Replication.grpcReplication(replicationSettings, producerFilter)(ShoppingCart.apply)
+    Replication.grpcReplication(replicationSettings, producerFilter)(ShoppingCart.applyWithProducerFilter)
   }
 
   def applyWithProducerFilter(replicatedBehaviors: ReplicatedBehaviors[Command, Event, State]): Behavior[Command] = {