in pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/MainApp.java [29:48]
public static void main(String[] args) {
if (args.length == 0) {
startClusterInSameJvm();
} else if (args[0].equals("cassandra")) {
startCassandraDatabase();
System.out.println("Started Apache Cassandra, press Ctrl + C to kill");
try {
new CountDownLatch(1).await();
} catch (InterruptedException e) {}
} else {
int port = Integer.parseInt(args[0]);
String dc;
if (args.length > 1)
dc = args[1];
else
dc = "eu-west";
startNode(port, dc);
}
}