diff --git a/cluster/cluster.go b/cluster/cluster.go index 86c5c7e..525b5e3 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -469,6 +469,11 @@ func (cls *Cluster) GetNodeInfo(nodeId string) (NodeInfo,bool) { func (dc *Cluster) CanDiscoveryService(fromMasterNodeId string,serviceName string) bool{ canDiscovery := true + splitServiceName := strings.Split(serviceName,":") + if len(splitServiceName) == 2 { + serviceName = splitServiceName[0] + } + for i:=0;i