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

Sending too fast to have replicas be caught up enough to register direct subs

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2023-08-31 15:16:19 -07:00
parent d7ea3b94d9
commit afb052651a
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/norace_test.go
View File

@@ -5205,16 +5205,15 @@ func TestNoRaceJetStreamClusterDirectAccessAllPeersSubs(t *testing.T) {
wg.Add(1)
go func() {
defer wg.Done()
nc, _ := jsClientConnect(t, c.randomServer())
nc, js := jsClientConnect(t, c.randomServer())
defer nc.Close()
js, _ := nc.JetStream(nats.MaxWait(500 * time.Millisecond))
for {
select {
case <-qch:
return
default:
// Send as fast as we can.
js.PublishAsync(fmt.Sprintf("kv.%d", rand.Intn(1000)), msg)
js.Publish(fmt.Sprintf("kv.%d", rand.Intn(1000)), msg)
}
}
}()