|
Akka/Scala example source code file (MembershipChangeListenerExitingSpec.scala)
The MembershipChangeListenerExitingSpec.scala Akka example source code/** * Copyright (C) 2009-2014 Typesafe Inc. <http://www.typesafe.com> */ package akka.cluster import scala.collection.immutable.SortedSet import org.scalatest.BeforeAndAfter import com.typesafe.config.ConfigFactory import akka.remote.testkit.MultiNodeConfig import akka.remote.testkit.MultiNodeSpec import akka.testkit._ import scala.concurrent.duration._ import akka.actor.Props import akka.actor.Actor import akka.cluster.MemberStatus._ import akka.actor.Deploy object MembershipChangeListenerExitingMultiJvmSpec extends MultiNodeConfig { val first = role("first") val second = role("second") val third = role("third") commonConfig(debugConfig(on = false).withFallback(MultiNodeClusterSpec.clusterConfigWithFailureDetectorPuppet)) } class MembershipChangeListenerExitingMultiJvmNode1 extends MembershipChangeListenerExitingSpec class MembershipChangeListenerExitingMultiJvmNode2 extends MembershipChangeListenerExitingSpec class MembershipChangeListenerExitingMultiJvmNode3 extends MembershipChangeListenerExitingSpec abstract class MembershipChangeListenerExitingSpec extends MultiNodeSpec(MembershipChangeListenerExitingMultiJvmSpec) with MultiNodeClusterSpec { import MembershipChangeListenerExitingMultiJvmSpec._ import ClusterEvent._ "A registered MembershipChangeListener" must { "be notified when new node is EXITING" taggedAs LongRunningTest in { awaitClusterUp(first, second, third) runOn(first) { enterBarrier("registered-listener") cluster.leave(second) } runOn(second) { val exitingLatch = TestLatch() val removedLatch = TestLatch() val secondAddress = address(second) cluster.subscribe(system.actorOf(Props(new Actor { def receive = { case state: CurrentClusterState ⇒ if (state.members.exists(m ⇒ m.address == secondAddress && m.status == Exiting)) exitingLatch.countDown() case MemberExited(m) if m.address == secondAddress ⇒ exitingLatch.countDown() case MemberRemoved(m, Exiting) if m.address == secondAddress ⇒ removedLatch.countDown() case _ ⇒ // ignore } }).withDeploy(Deploy.local)), classOf[MemberEvent]) enterBarrier("registered-listener") exitingLatch.await removedLatch.await } runOn(third) { val exitingLatch = TestLatch() val secondAddress = address(second) cluster.subscribe(system.actorOf(Props(new Actor { def receive = { case state: CurrentClusterState ⇒ if (state.members.exists(m ⇒ m.address == secondAddress && m.status == Exiting)) exitingLatch.countDown() case MemberExited(m) if m.address == secondAddress ⇒ exitingLatch.countDown() case _ ⇒ // ignore } }).withDeploy(Deploy.local)), classOf[MemberEvent]) enterBarrier("registered-listener") exitingLatch.await } enterBarrier("finished") } } } Other Akka source code examplesHere is a short list of links related to this Akka MembershipChangeListenerExitingSpec.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.