collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-04-24 10:38:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
joy.zhou
2019-08-01 10:17:21 +08:00
parent 8259670c12
commit f91ed68946
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
broker/rpc.go
View File

@@ -171,7 +171,10 @@ func (b *Broker) QueryShareSubscribe(topic string, qos byte) map[string]int32 {
log.Error("rpc request error:", zap.Error(err))
continue
}
result[id] = resp.ShareSubCount
if resp.ShareSubCount > 0 {
result[id] = resp.ShareSubCount
}
}
return result
}