Skip to content

Commit 2131a5c

Browse files
committed
Increasing timeouts for nats response.
1 parent 2784128 commit 2131a5c

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

autonats/server.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -379,8 +379,8 @@ func StartServer(opts Options) (srv *Server, err error) {
379379

380380
// Try messaging the jetstream API up to 5 times
381381
var jserr error
382-
for i := 0; i < 5; i++ {
383-
_, jserr = conn.Request("$JS.API.INFO", nil, 100*time.Millisecond)
382+
for i := 1; i <= 10; i++ {
383+
_, jserr = conn.Request("$JS.API.INFO", nil, time.Duration(i*100)*time.Millisecond)
384384
if jserr == nil {
385385
break
386386
}

revision/self.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77
)
88

99
var (
10-
VersionString = "v0.3" // Only updated for major/minor releases.
10+
VersionString = "v0.4" // Only updated for major/minor releases.
1111
)
1212

1313
func getCommit() string {

0 commit comments

Comments
 (0)