gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity

More changes

Browse Source
This commit is contained in:
Ivan Kozlovic
2018-03-06 10:13:51 -07:00
parent 0ac50bda76
commit 92796d74e1
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/configs/auth_seed.conf
View File

@@ -2,7 +2,7 @@
# Cluster Seed Node
listen: 127.0.0.1:4222
listen: 127.0.0.1:5222
http: 8222

2
test/configs/override.conf
View File

@@ -2,7 +2,7 @@
# Config file to test overrides to client
listen: 127.0.0.1:4224
listen: 127.0.0.1:5224
# maximum payload
max_payload: 2222

2
test/configs/seed.conf
View File

@@ -2,7 +2,7 @@
# Cluster Seed Node
listen: 127.0.0.1:4222
listen: 127.0.0.1:5222
http: 8222

8
test/routes_test.go
View File

@@ -496,7 +496,7 @@ func TestRouteResendsLocalSubsOnReconnect(t *testing.T) {
route := createRouteConn(t, opts.Cluster.Host, opts.Cluster.Port)
defer route.Close()
routeSend, routeExpect := setupRouteEx(t, route, opts, "ROUTE:4222")
routeSend, routeExpect := setupRouteEx(t, route, opts, "ROUTE:1234")
// Expect to see the local sub echoed through after we send our INFO.
time.Sleep(50 * time.Millisecond)
@@ -507,7 +507,7 @@ func TestRouteResendsLocalSubsOnReconnect(t *testing.T) {
if err := json.Unmarshal(buf[4:], &info); err != nil {
t.Fatalf("Could not unmarshal route info: %v", err)
}
info.ID = "ROUTE:4222"
info.ID = "ROUTE:1234"
b, err := json.Marshal(info)
if err != nil {
t.Fatalf("Could not marshal test route info: %v", err)
@@ -525,7 +525,7 @@ func TestRouteResendsLocalSubsOnReconnect(t *testing.T) {
route = createRouteConn(t, opts.Cluster.Host, opts.Cluster.Port)
defer route.Close()
routeSend, routeExpect = setupRouteEx(t, route, opts, "ROUTE:4222")
routeSend, routeExpect = setupRouteEx(t, route, opts, "ROUTE:1234")
routeExpect(infoRe)
@@ -600,7 +600,7 @@ func TestRouteConnectOnShutdownRace(t *testing.T) {
for {
route := createRouteConn(l, opts.Cluster.Host, opts.Cluster.Port)
if route != nil {
setupRouteEx(l, route, opts, "ROUTE:4222")
setupRouteEx(l, route, opts, "ROUTE:1234")
route.Close()
}
select {