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

Flush SUB to route

Browse Source
This commit is contained in:
Derek Collison
2013-07-30 15:39:53 -07:00
parent f015b7ca45
commit 32ff571f3e
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
test/routes_test.go
View File

@@ -139,7 +139,7 @@ func TestRouteForwardsMsgFromClients(t *testing.T) {
client := createClientConn(t, opts.Host, opts.Port)
defer client.Close()
clientSend, _ := setupConn(t, client)
clientSend, clientExpect := setupConn(t, client)
route := acceptRouteConn(t, opts.Routes[0].Host, server.DEFAULT_ROUTE_CONNECT)
defer route.Close()
@@ -152,9 +152,13 @@ func TestRouteForwardsMsgFromClients(t *testing.T) {
// Send SUB via route connection
routeSend("SUB foo RSID:2:22\r\n")
routeSend("PING\r\n")
routeExpect(pongRe)
// Send PUB via client connection
clientSend("PUB foo 2\r\nok\r\n")
clientSend("PING\r\n")
clientExpect(pongRe)
matches := expectMsgs(1)
checkMsg(t, matches[0], "foo", "RSID:2:22", "", "2", "ok")
@@ -346,12 +350,10 @@ func TestMultipleRoutesSameId(t *testing.T) {
route1 := createRouteConn(t, opts.ClusterHost, opts.ClusterPort)
expectAuthRequired(t, route1)
route1Send, _ := setupRouteEx(t, route1, opts, "ROUTE:2222")
// route1ExpectMsgs := expectMsgsCommand(t, route1Expect)
route2 := createRouteConn(t, opts.ClusterHost, opts.ClusterPort)
expectAuthRequired(t, route2)
route2Send, _ := setupRouteEx(t, route2, opts, "ROUTE:2222")
// route2ExpectMsgs := expectMsgsCommand(t, route1Expect)
// Send SUB via route connections
sub := "SUB foo RSID:2:22\r\n"