gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Should receive msgs

Browse Source
This commit is contained in:
Derek Collison
2014-04-05 00:06:19 +02:00
parent 53c5674ce5
commit ff2e2d40ae
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/cluster_test.go
View File

@@ -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)