diff --git a/cluster/dynamicdiscovery.go b/cluster/dynamicdiscovery.go index 6293cd4..e797610 100644 --- a/cluster/dynamicdiscovery.go +++ b/cluster/dynamicdiscovery.go @@ -302,6 +302,11 @@ func (dc *DynamicDiscoveryClient) RPC_SubServiceDiscover(req *rpc.SubscribeDisco for _, nodeInfo := range mapNodeInfo { dc.addMasterNode(req.MasterNodeId, nodeInfo.NodeId) dc.setNodeInfo(nodeInfo) + + if len(nodeInfo.PublicServiceList) == 0 { + continue + } + cluster.TriggerDiscoveryEvent(true,int(nodeInfo.NodeId),nodeInfo.PublicServiceList) }