From 0439e7ce906a7222a1e051f36934e79e3facc24a Mon Sep 17 00:00:00 2001 From: zhouyuyan Date: Mon, 22 Jan 2018 09:30:08 +0800 Subject: [PATCH] fxi ws conn --- broker/broker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/broker.go b/broker/broker.go index 74990b6..04defa9 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -328,7 +328,7 @@ func (b *Broker) handleConnection(typ int, conn net.Conn, idx uint64) { b.routes.Store(cid, c) } - go c.readLoop() + c.readLoop() } func (b *Broker) ConnectToDiscovery() {