From ff2e2d40ae62d7069a31261324d6cafb19c4480c Mon Sep 17 00:00:00 2001
From: Derek Collison <derek@apcera.com>
Date: Sat, 5 Apr 2014 00:06:19 +0200
Subject: [PATCH] Should receive msgs

---
 test/cluster_test.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/test/cluster_test.go b/test/cluster_test.go
index 5c1493e2..3c531bb0 100644
--- a/test/cluster_test.go
+++ b/test/cluster_test.go
@@ -3,7 +3,7 @@
 package test
 
 import (
-"fmt"
+	"fmt"
 	"testing"
 	"time"
 
@@ -161,6 +161,11 @@ func TestClusterQueueSubs(t *testing.T) {
 
 	// Send to B
 	sendB("PUB foo 2\r\nok\r\n")
+
+	// Should receive 1 from B.
+	matches = expectMsgsB(1)
+	checkForQueueSid(t, matches, qg2Sids_b)
+
 	sendB("PING\r\n")
 	expectB(pongRe)
 
@@ -239,8 +244,6 @@ func TestClusterDoubleMsgs(t *testing.T) {
 	// Close ClientA1
 	clientA1.Close()
 
-//	time.Sleep(time.Second)
-
 	sendB("PUB foo 2\r\nok\r\n")
 	sendB("PING\r\n")
 	expectB(pongRe)