mirror of
https://github.com/fhmq/hmq.git
synced 2026-04-24 10:38:34 +00:00
fxi ws conn
This commit is contained in:
@@ -328,7 +328,7 @@ func (b *Broker) handleConnection(typ int, conn net.Conn, idx uint64) {
|
|||||||
b.routes.Store(cid, c)
|
b.routes.Store(cid, c)
|
||||||
}
|
}
|
||||||
|
|
||||||
go c.readLoop()
|
c.readLoop()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *Broker) ConnectToDiscovery() {
|
func (b *Broker) ConnectToDiscovery() {
|
||||||
|
|||||||
Reference in New Issue
Block a user