From f2efaa999221763b9015eceef708d8f5d2d60c87 Mon Sep 17 00:00:00 2001 From: zhouyuyan Date: Fri, 8 Sep 2017 10:44:53 +0800 Subject: [PATCH] lb --- broker/client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/client.go b/broker/client.go index 869eafa..47b4a7f 100644 --- a/broker/client.go +++ b/broker/client.go @@ -226,7 +226,7 @@ func (c *client) ProcessPublishMessage(packet *packets.PublishPacket) { t := "$queue/" + topic cnt, exist := b.queues[t] if exist { - log.Info("queue index : ", cnt) + // log.Info("queue index : ", cnt) for _, sub := range r.qsubs { if sub.client.typ == ROUTER { if c.typ == ROUTER {