diff --git a/server/const.go b/server/const.go index 1993f102..5762d60b 100644 --- a/server/const.go +++ b/server/const.go @@ -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 diff --git a/server/stream.go b/server/stream.go index 1714b200..2db0c62d 100644 --- a/server/stream.go +++ b/server/stream.go @@ -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_ {