mirror of
https://github.com/fhmq/hmq.git
synced 2026-08-30 22:34:52 +00:00
config rpc port
This commit is contained in:
+1
-2
@@ -131,14 +131,13 @@ func (b *Broker) Start() {
|
||||
return
|
||||
}
|
||||
|
||||
go b.initRPCService()
|
||||
|
||||
go InitHTTPMoniter(b)
|
||||
|
||||
//connet to router
|
||||
if b.config.Router != "" {
|
||||
go b.ConnectToDiscovery()
|
||||
go b.processClusterInfo()
|
||||
go b.initRPCService()
|
||||
}
|
||||
|
||||
//listen for websocket
|
||||
|
||||
Reference in New Issue
Block a user