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 index a64a6df0d..b8af8cd96 100644 --- 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 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 createWithProducerFilter( diff --git a/samples/replicated/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala b/samples/replicated/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala index 448df2910..6f5cccc26 100644 --- a/samples/replicated/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala +++ b/samples/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] = {