refreshWorkers

gistfile1.scala

def refreshWorkers() {
  val cs = clusterService.clusterStatus
  for (participant <- cs.participants) {

    val path = if (cs.current == participant)
      akkaConfig.localActorPath(workerPath)
    else
      remotePathForParticipant(
         akkaConfig, participant, workerPath)

    val remoteRef = context.actorFor(path)

    if (workers.get(remoteRef).isEmpty) 
      workers += remoteRef->None
 }
}