From 97471f94c659022a8aa0b4ea57ff2e1063ccd4ab Mon Sep 17 00:00:00 2001
From: Patrik Nordwall <patrik.nordwall@gmail.com>
Date: Fri, 31 May 2013 14:19:13 +0200
Subject: [PATCH] Increase timeouts in ConcurrentSocketActorSpec, see #3421

* Failure was caused by 2.6 s GC pause
---
 .../test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala b/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala
index 4697db8b23..eab6b3503a 100644
--- a/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala
+++ b/akka-zeromq/src/test/scala/akka/zeromq/ConcurrentSocketActorSpec.scala
@@ -58,7 +58,7 @@ class ConcurrentSocketActorSpec extends AkkaSpec {
 
       try {
         subscriberProbe.expectMsg(Connecting)
-        val msgNumbers = subscriberProbe.receiveWhile(2 seconds) {
+        val msgNumbers = subscriberProbe.receiveWhile(3 seconds) {
           case msg: ZMQMessage if msg.frames.size == 2 ⇒
             msg.frames(1).length must be(0)
             msg
@@ -69,7 +69,7 @@ class ConcurrentSocketActorSpec extends AkkaSpec {
         msgGenerator.cancel()
         system stop publisher
         system stop subscriber
-        subscriberProbe.receiveWhile(1 seconds) {
+        subscriberProbe.receiveWhile(3 seconds) {
           case msg ⇒ msg
         }.last must equal(Closed)
         awaitCond(publisher.isTerminated)