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

fix issue 25

Browse Source
This commit is contained in:
zhouyuyan
2018-04-28 09:08:28 +08:00
parent 5ed4728575
commit 56fb4a2d54
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
broker/client.go
View File

@@ -241,6 +241,10 @@ func (c *client) ProcessPublishMessage(packet *packets.PublishPacket) {
topic := packet.TopicName topic := packet.TopicName
r := b.sl.Match(topic) r := b.sl.Match(topic)
if r == nil {
return
}
// log.Info("psubs num: ", len(r.psubs)) // log.Info("psubs num: ", len(r.psubs))
if len(r.qsubs) == 0 && len(r.psubs) == 0 { if len(r.qsubs) == 0 && len(r.psubs) == 0 {
return return
@@ -403,6 +407,9 @@ func (c *client) ProcessSubscribe(packet *packets.SubscribePacket) {
//process retain message //process retain message
for _, t := range topics { for _, t := range topics {
packets := b.rl.Match(t) packets := b.rl.Match(t)
if packets == nil {
continue
}
for _, packet := range packets { for _, packet := range packets {
log.Info("process retain message: ", zap.Any("packet", packet), zap.String("ClientID", c.info.clientID)) log.Info("process retain message: ", zap.Any("packet", packet), zap.String("ClientID", c.info.clientID))
if packet != nil { if packet != nil {