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

Wait longer for response

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-03-09 05:41:00 -06:00
parent ccbb547a14
commit ea9abc5ef8
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/const.go
View File

@@ -41,7 +41,7 @@ var (
const (
// VERSION is the current version for the server.
VERSION = "2.2.0-RC.7.1"
VERSION = "2.2.0-RC.7.2"
// PROTO is the currently supported protocol.
// 0 was the original

2
server/stream.go
View File

@@ -1427,7 +1427,7 @@ func (mset *stream) setSourceConsumer(sname string, seq uint64) {
}
}
mset.mu.Unlock()
case <-time.After(5 * time.Second):
case <-time.After(10 * time.Second):
// Make sure things have not changed.
mset.mu.Lock()
if si := mset.sources[sname]; si != nil && si.cname == _EMPTY_ {