gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 03:00:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3118 from nats-io/fix_3117

Browse Source 
[FIXED] JetStream: panic processing cluster consumer create
This commit is contained in:
Ivan Kozlovic
2022-05-11 13:15:06 -06:00
committed by GitHub
parent 56d06fd8eb 5c3be1ee68
commit 7da46d546d
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/consumer.go
View File

@@ -2410,10 +2410,13 @@ func (wq *waitQueue) isFull() bool {
}
func (wq *waitQueue) isEmpty() bool {
return wq.n == 0
return wq.len() == 0
}
func (wq *waitQueue) len() int {
if wq == nil {
return 0
}
return wq.n
}