From 5a9a40bad1f8d7acb7bb05d63d971c198ba10ba8 Mon Sep 17 00:00:00 2001
From: Patrik Nordwall <patrik.nordwall@gmail.com>
Date: Wed, 11 Apr 2018 16:27:38 +0200
Subject: [PATCH] harden TransportFailSpec

---
 .../src/multi-jvm/scala/akka/remote/TransportFailSpec.scala  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala
index e18e2bda14..f60e6d7f90 100644
--- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala
+++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/TransportFailSpec.scala
@@ -102,8 +102,9 @@ abstract class TransportFailSpec extends RemotingMultiNodeSpec(TransportFailConf
   override def initialParticipants = roles.size
 
   def identify(role: RoleName, actorName: String): ActorRef = {
-    system.actorSelection(node(role) / "user" / actorName) ! Identify(actorName)
-    expectMsgType[ActorIdentity].ref.get
+    val p = TestProbe()
+    (system.actorSelection(node(role) / "user" / actorName)).tell(Identify(actorName), p.ref)
+    p.expectMsgType[ActorIdentity](remainingOrDefault).ref.get
   }
 
   "TransportFail" must {