raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

fix reliable delivery doc example #31026 (#31027)

Browse source
This commit is contained in:
AndyChen 2022-01-03 16:17:45 +08:00 • committed by GitHub
parent 860681ce81
commit 799255ef6c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-cluster-sharding-typed/src/test/java/jdocs/delivery/ShardingDocExample.java
View file

@ -406,7 +406,7 @@ interface ShardingDocExample {
Behaviors.setup(
context -> {
// #init
final DB db = theDatbaseImplementation();
final DB db = theDatabaseImplementation();
ActorSystem<Void> 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<ShardingProducerController.Command<TodoList.Command>> producerController =
context.spawn(
@ -439,7 +439,7 @@ interface ShardingDocExample {
});
}
static DB theDatbaseImplementation() {
static DB theDatabaseImplementation() {
return null;
}
}