in pekko-sample-cluster-java/src/main/java/sample/cluster/transformation/App.java [18:34]
static Behavior<Void> create() {
return Behaviors.setup(context -> {
Cluster cluster = Cluster.get(context.getSystem());
if (cluster.selfMember().hasRole("backend")) {
int workersPerNode = context.getSystem().settings().config().getInt("transformation.workers-per-node");
for (int i = 0; i < workersPerNode; i++) {
context.spawn(Worker.create(), "Worker" + i);
}
}
if (cluster.selfMember().hasRole("frontend")) {
context.spawn(Frontend.create(), "Frontend");
}
return Behaviors.empty();
});
}