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

Merge pull request #1774 from nats-io/qw_flapper

Browse Source 
Fix flapper
This commit is contained in:
Derek Collison
2020-12-14 08:20:36 -08:00
committed by GitHub
parent d5f255b98e ced28eca93
commit e7106df78b
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
test/jetstream_test.go
View File

@@ -1679,9 +1679,12 @@ func TestJetStreamWorkQueueWrapWaiting(t *testing.T) {
}
expectWaiting(0)
if nmsgs, _, _ := sub.Pending(); err != nil || nmsgs != maxWaiting+2 {
t.Fatalf("Expected sub to have %d pending, got %d", maxWaiting+2, nmsgs)
}
checkFor(t, 200*time.Millisecond, 10*time.Millisecond, func() error {
if nmsgs, _, _ := sub.Pending(); err != nil || nmsgs != maxWaiting+2 {
return fmt.Errorf("Expected sub to have %d pending, got %d", maxWaiting+2, nmsgs)
}
return nil
})
})
}
}