Akka MultiJVM testing example with barriers

XampleSpec.scala

package sample
 
import org.scalatest.WordSpec
import org.scalatest.matchers.MustMatchers
import org.scalatest.BeforeAndAfterAll
import akka.remote.AbstractRemoteActorMultiJvmSpec
import akka.remote.AkkaRemoteSpec

object XampleMultiJvmSpec extends AbstractRemoteActorMultiJvmSpec {
override def NrOfNodes = 2
  def commonConfig = ConfigFactory.parseString("""
    // Declare your configuration here.
  """)
}

class XampleMultiJvmNode1 extends AkkaRemoteSpec(XampleMultiJvmSpec.nodeConfigs(0))
  with WordSpec with MustMatchers {
  import XampleMultiJvmSpec._
  val nodes = NrOfNodes
  
  "A cluster" must {
 
    "have config options" in {
      config.getString("akka.remote.netty.hostname") must be("localhost")
      config.getString("akka.remote.netty.port") must be("1991")
    }
 
    "be able to start all nodes" in {
      barrier("start")
      println("All nodes are started!")
      barrier("end")
    }
  }
}
 
class XampleMultiJvmNode2 extends AkkaRemoteSpec(XampleMultiJvmSpec.nodeConfigs(1))
  with WordSpec with MustMatchers {
  import XampleMultiJvmSpec._
  val nodes = NrOfNodes
 
  "A cluster" must {
 
    "have config options" in {
      config.getString("akka.remote.netty.hostname") must be("localhost")
      config.getString("akka.remote.netty.port") must be("1992")
    }
 
    "be able to start all nodes" in {
      barrier("start")
      println("All nodes are started!")
      barrier("end")
    }
  }
}