Skip to content

Commit

Permalink
Make consistent with TestNoRaceJetStreamClusterGhostConsumers
Browse files Browse the repository at this point in the history
Signed-off-by: Maurice van Veen <github@mauricevanveen.com>
  • Loading branch information
MauriceVanVeen committed Oct 2, 2024
1 parent d171ae8 commit b45f105
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions server/jetstream_cluster_3_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1644,9 +1644,8 @@ func TestJetStreamClusterGhostEphemeralsAfterRestart(t *testing.T) {
defer nc.Close()

subj := fmt.Sprintf(JSApiConsumerListT, "TEST")
checkFor(t, 20*time.Second, 200*time.Millisecond, func() error {
// Request will take at most 4 seconds if some consumers can't be found.
m, err := nc.Request(subj, nil, 5*time.Second)
checkFor(t, 30*time.Second, time.Second, func() error {
m, err := nc.Request(subj, nil, time.Second)
if err != nil {
return err
}
Expand Down

0 comments on commit b45f105

Please sign in to comment.