From 799255ef6c8b430bbc8c05b12b87b3fdd56e08d7 Mon Sep 17 00:00:00 2001 From: AndyChen Date: Mon, 3 Jan 2022 16:17:45 +0800 Subject: [PATCH] fix reliable delivery doc example #31026 (#31027) --- .../src/test/java/jdocs/delivery/ShardingDocExample.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java b/akka-cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java index 6103a9ea2c..e5201046f3 100644 --- a/akka-cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java +++ b/akka-cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java @@ -406,7 +406,7 @@ interface ShardingDocExample { Behaviors.setup( context -> { // #init - final DB db = theDatbaseImplementation(); + final DB db = theDatabaseImplementation(); ActorSystem system = context.getSystem(); @@ -424,7 +424,7 @@ interface ShardingDocExample { TodoList.create(entityContext.getEntityId(), db, start)))); Address selfAddress = Cluster.get(system).selfMember().address(); - String producerId = "todo-producer-" + selfAddress.host() + ":" + selfAddress.port(); + String producerId = "todo-producer-" + selfAddress.hostPort(); ActorRef> producerController = context.spawn( @@ -439,7 +439,7 @@ interface ShardingDocExample { }); } - static DB theDatbaseImplementation() { + static DB theDatabaseImplementation() { return null; } }