Hi All.
There are two hosts on EC2: H1 and H2. There are tree modules of
sbt-project: master, clientand worker. Each module implement akka-cluster
node, which subscribes to a cluster events and logs them. Also each node
logs a cluster state every 1 minute (for debug). The following ports are
There is the following actor which belongs to cluster and is subscribed to
cluster events:
class Worker extends Actor {
val cluster = Cluster(context.system)
var router = Router(BroadcastRoutingLogic(), Vector.empty[
ActorRefRoutee])
override def preStart(): Unit =
