|
|
@ -267,6 +267,8 @@ func (ws *WsServer) registerClient(client *Client) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
wg := sync.WaitGroup{}
|
|
|
|
wg := sync.WaitGroup{}
|
|
|
|
|
|
|
|
log.ZDebug(client.ctx, "ws.msgGatewayConfig.Discovery.Enable", ws.msgGatewayConfig.Discovery.Enable)
|
|
|
|
|
|
|
|
|
|
|
|
if ws.msgGatewayConfig.Discovery.Enable != "k8s" {
|
|
|
|
if ws.msgGatewayConfig.Discovery.Enable != "k8s" {
|
|
|
|
wg.Add(1)
|
|
|
|
wg.Add(1)
|
|
|
|
go func() {
|
|
|
|
go func() {
|
|
|
|