|
Akka/Scala example source code file (MembershipChangeListenerUpSpec.scala)
The MembershipChangeListenerUpSpec.scala Akka example source code/** * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com> */ package akka.cluster import scala.collection.immutable.SortedSet import com.typesafe.config.ConfigFactory import akka.remote.testkit.MultiNodeConfig import akka.remote.testkit.MultiNodeSpec import akka.testkit._ import akka.actor.Props import akka.actor.Actor import akka.actor.Deploy object MembershipChangeListenerUpMultiJvmSpec extends MultiNodeConfig { val first = role("first") val second = role("second") val third = role("third") commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfigWithFailureDetectorPuppet)) } class MembershipChangeListenerUpMultiJvmNode1 extends MembershipChangeListenerUpSpec class MembershipChangeListenerUpMultiJvmNode2 extends MembershipChangeListenerUpSpec class MembershipChangeListenerUpMultiJvmNode3 extends MembershipChangeListenerUpSpec abstract class MembershipChangeListenerUpSpec extends MultiNodeSpec(MembershipChangeListenerUpMultiJvmSpec) with MultiNodeClusterSpec { import MembershipChangeListenerUpMultiJvmSpec._ import ClusterEvent._ "A set of connected cluster systems" must { "(when two nodes) after cluster convergence updates the membership table then all MembershipChangeListeners should be triggered" taggedAs LongRunningTest in { awaitClusterUp(first) runOn(first, second) { val latch = TestLatch() val expectedAddresses = Set(first, second) map address cluster.subscribe(system.actorOf(Props(new Actor { var members = Set.empty[Member] def receive = { case state: CurrentClusterState ⇒ members = state.members case MemberUp(m) ⇒ members = members - m + m if (members.map(_.address) == expectedAddresses) latch.countDown() case _ ⇒ // ignore } }).withDeploy(Deploy.local)), classOf[MemberEvent]) enterBarrier("listener-1-registered") cluster.join(first) latch.await } runOn(third) { enterBarrier("listener-1-registered") } enterBarrier("after-1") } "(when three nodes) after cluster convergence updates the membership table then all MembershipChangeListeners should be triggered" taggedAs LongRunningTest in { val latch = TestLatch() val expectedAddresses = Set(first, second, third) map address cluster.subscribe(system.actorOf(Props(new Actor { var members = Set.empty[Member] def receive = { case state: CurrentClusterState ⇒ members = state.members case MemberUp(m) ⇒ members = members - m + m if (members.map(_.address) == expectedAddresses) latch.countDown() case _ ⇒ // ignore } }).withDeploy(Deploy.local)), classOf[MemberEvent]) enterBarrier("listener-2-registered") runOn(third) { cluster.join(first) } latch.await enterBarrier("after-2") } } } Other Akka source code examplesHere is a short list of links related to this Akka MembershipChangeListenerUpSpec.scala source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.