static Behavior create()

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();
      });
    }