From f91ed6894642a362067bbea4def394484f7561b7 Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Thu, 1 Aug 2019 10:17:21 +0800 Subject: [PATCH] update --- broker/rpc.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/broker/rpc.go b/broker/rpc.go index 7aa8649..287b89f 100644 --- a/broker/rpc.go +++ b/broker/rpc.go @@ -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 }