|
Akka/Scala example source code file (SimpleClusterApp.java)
The SimpleClusterApp.java Akka example source codepackage sample.cluster.simple; import akka.actor.ActorSystem; import akka.actor.Props; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; public class SimpleClusterApp { public static void main(String[] args) { if (args.length == 0) startup(new String[] { "2551", "2552", "0" }); else startup(args); } public static void startup(String[] ports) { for (String port : ports) { // Override the configuration of the port Config config = ConfigFactory.parseString( "akka.remote.netty.tcp.port=" + port).withFallback( ConfigFactory.load()); // Create an Akka system ActorSystem system = ActorSystem.create("ClusterSystem", config); // Create an actor that handles cluster domain events system.actorOf(Props.create(SimpleClusterListener.class), "clusterListener"); } } } Other Akka source code examplesHere is a short list of links related to this Akka SimpleClusterApp.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.