From 8f29022ef51f7e5affac51d5de9ddbe8abff1201 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bj=C3=B6rn=20Antonsson?= Date: Fri, 18 Jan 2013 15:00:19 +0100 Subject: [PATCH] Terminate zeromq context after actors have terminated. See #2838 --- .../test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala b/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala index 8a5624126f..8eb10ff79c 100644 --- a/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala +++ b/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala @@ -99,6 +99,8 @@ class ConcurrentSocketActorSpec extends AkkaSpec { system stop requester system stop replier replierProbe.expectMsg(Closed) + awaitCond(requester.isTerminated) + awaitCond(replier.isTerminated) context.term } } @@ -120,6 +122,8 @@ class ConcurrentSocketActorSpec extends AkkaSpec { system stop pusher system stop puller pullerProbe.expectMsg(Closed) + awaitCond(pusher.isTerminated) + awaitCond(puller.isTerminated) context.term } }