Fixed tests

This commit is contained in:
Lev Brouk
2023-07-19 04:24:09 -07:00
parent 4a19059002
commit 46a38929d9
3 changed files with 3 additions and 4 deletions

View File

@@ -2686,7 +2686,6 @@ func (s *Server) nsubsRequest(sub *subscription, c *client, _ *Account, subject,
s.sendInternalMsgLocked(reply, _EMPTY_, nil, nsubs)
}
// accountClaimUpdate will receive claim updates for accounts.
func (s *Server) reloadConfig(sub *subscription, c *client, _ *Account, subject, reply string, hdr, msg []byte) {
if !s.eventsRunning() {
return

View File

@@ -1666,7 +1666,7 @@ func TestSystemAccountWithGateways(t *testing.T) {
// If this tests fails with wrong number after 10 seconds we may have
// added a new inititial subscription for the eventing system.
checkExpectedSubs(t, 52, sa)
checkExpectedSubs(t, 53, sa)
// Create a client on B and see if we receive the event
urlb := fmt.Sprintf("nats://%s:%d", ob.Host, ob.Port)
@@ -2620,7 +2620,7 @@ func TestServerEventsReload(t *testing.T) {
require_True(t, apiResp.Data == nil)
require_Error(t, apiResp.Error, fmt.Errorf("Parse error on line 1: 'Expected a top-level value to end with a new line, comment or EOF, but got 'n' instead.'"))
// See that the ping interval has changed.
// See that the ping interval has not changed.
require_True(t, s.getOpts().PingInterval == 200*time.Millisecond)
}

View File

@@ -3945,7 +3945,7 @@ func TestMonitorAccountz(t *testing.T) {
body = string(readBody(t, fmt.Sprintf("http://127.0.0.1:%d%s?acc=$SYS", s.MonitorAddr().Port, AccountzPath)))
require_Contains(t, body, `"account_detail": {`)
require_Contains(t, body, `"account_name": "$SYS",`)
require_Contains(t, body, `"subscriptions": 46,`)
require_Contains(t, body, `"subscriptions": 47,`)
require_Contains(t, body, `"is_system": true,`)
require_Contains(t, body, `"system_account": "$SYS"`)