def main()

in pekko-sample-distributed-workers-scala/src/main/scala/worker/Main.scala [20:38]


  def main(args: Array[String]): Unit = {
    args.headOption match {

      case None =>
        startClusterInSameJvm()

      case Some(portString) if portString.matches("""\d+""") =>
        val port = portString.toInt
        if (backEndPortRange.contains(port)) start(port, "back-end")
        else if (frontEndPortRange.contains(port)) start(port, "front-end")
        else start(port, "worker", args.lift(1).map(_.toInt).getOrElse(1))

      case Some("cassandra") =>
        startCassandraDatabase()
        println("Started Apache Cassandra, press Ctrl + C to kill")
        new CountDownLatch(1).await()

    }
  }