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

Updated tests for addition of ErrNoResponders

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2020-10-19 20:11:52 -07:00
parent 610d2d21b7
commit a37f53e236
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
server/jwt_test.go
View File

@@ -2130,7 +2130,7 @@ func TestAccountURLResolverFetchFailureInCluster(t *testing.T) {
cluster {
name: clust
no_advertise: true
listen: -1
listen: -1
routes [
nats-route://localhost:%d
]
@@ -3407,7 +3407,7 @@ func TestAccountNATSResolverFetch(t *testing.T) {
}
cluster {
name: clust
listen: -1
listen: -1
no_advertise: true
routes [
nats-route://localhost:%d
@@ -3431,7 +3431,7 @@ func TestAccountNATSResolverFetch(t *testing.T) {
}
cluster {
name: clust
listen: -1
listen: -1
no_advertise: true
routes [
nats-route://localhost:%d
@@ -3650,7 +3650,7 @@ func TestAccountNATSResolverCrossClusterFetch(t *testing.T) {
}
cluster {
name: clust-A
listen: -1
listen: -1
no_advertise: true
routes [
nats-route://localhost:%d
@@ -4107,7 +4107,7 @@ func TestJWTJetStreamLimits(t *testing.T) {
}
expect_JSDisabledForAccount := func(c *nats.Conn) {
t.Helper()
if _, err := c.Request("$JS.API.INFO", nil, time.Second); err != nats.ErrTimeout {
if _, err := c.Request("$JS.API.INFO", nil, time.Second); err != nats.ErrTimeout && err != nats.ErrNoResponders {
t.Fatalf("Unexpected error: %v", err)
}
}

2
server/reload_test.go
View File

@@ -3180,7 +3180,7 @@ func TestConfigReloadAccountServicesImportExport(t *testing.T) {
if string(msg.Data) != reply {
t.Fatalf("Expected reply %s on subject %s, got %s", reply, subj, msg.Data)
}
} else if err != nats.ErrTimeout {
} else if err != nats.ErrTimeout && err != nats.ErrNoResponders {
t.Fatalf("Expected timeout on subject %s, got %v", subj, err)
}
}