collab/hmq
3
0 Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-11-02 14:39:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

lb

Browse Source
This commit is contained in:
zhouyuyan committed 2017-09-08 12:22:51 +08:00
1 parent f2efaa9992
commit 35390baa92
1 file changed
+2 -2
Download Patch File Download Diff File Expand all files Collapse all files
broker/client.go
+2 -2
View File
@@ -221,7 +221,7 @@ func (c *client) ProcessPublishMessage(packet *packets.PublishPacket) {
} }
} }
pre := 0 pre := -1
now := -1 now := -1
t := "$queue/" + topic t := "$queue/" + topic
cnt, exist := b.queues[t] cnt, exist := b.queues[t]
@@ -238,7 +238,7 @@ func (c *client) ProcessPublishMessage(packet *packets.PublishPacket) {
} else { } else {
now = now + sub.client.rsubs[t].num now = now + sub.client.rsubs[t].num
} }
if cnt >= pre && cnt <= now { if cnt > pre && cnt <= now {
if sub != nil { if sub != nil {
err := sub.client.WriterPacket(packet) err := sub.client.WriterPacket(packet)
if err != nil { if err != nil {