raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

#3322 - Changing the name of the bigBounce actor in RemotingSpec to a unique one so that there is no race between tests.

Browse source
This commit is contained in:
Viktor Klang 2013-05-09 20:43:06 +02:00
parent 325ea283cb
commit a4bce44dce
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-remote/src/test/scala/akka/remote/RemotingSpec.scala
View file

@ -13,6 +13,7 @@ import java.io.NotSerializableException
import scala.concurrent.Await
import scala.concurrent.Future
import scala.concurrent.duration._
import scala.concurrent.forkjoin.ThreadLocalRandom
object RemotingSpec {
@ -159,13 +160,14 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D
val here = system.actorFor("akka.test://remote-sys@localhost:12346/user/echo")
private def verifySend(msg: Any)(afterSend: ⇒ Unit) {
val bigBounceId = s"bigBounce-${ThreadLocalRandom.current.nextInt()}"
val bigBounceOther = remoteSystem.actorOf(Props(new Actor {
def receive = {
case x: Int ⇒ sender ! byteStringOfSize(x)
case x ⇒ sender ! x
}
}), "bigBounce")
val bigBounceHere = system.actorFor("akka.test://remote-sys@localhost:12346/user/bigBounce")
}), bigBounceId)
val bigBounceHere = system.actorFor(s"akka.test://remote-sys@localhost:12346/user/$bigBounceId")
val eventForwarder = system.actorOf(Props(new Actor {
def receive = {
@ -181,8 +183,8 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D
} finally {
system.eventStream.unsubscribe(eventForwarder, classOf[AssociationErrorEvent])
system.eventStream.unsubscribe(eventForwarder, classOf[DisassociatedEvent])
system.stop(eventForwarder)
remoteSystem.stop(bigBounceOther)
eventForwarder ! PoisonPill
bigBounceOther ! PoisonPill
}
}