diff --git a/cluster/origindiscovery.go b/cluster/origindiscovery.go index b9047af..5f50471 100644 --- a/cluster/origindiscovery.go +++ b/cluster/origindiscovery.go @@ -160,6 +160,12 @@ func (dc *OriginDiscoveryMaster) OnNatsDisconnect(){ } func (ds *OriginDiscoveryMaster) OnNodeConnected(nodeId string) { + var notifyDiscover rpc.SubscribeDiscoverNotify + notifyDiscover.IsFull = true + notifyDiscover.NodeInfo = ds.nodeInfo + notifyDiscover.MasterNodeId = cluster.GetLocalNodeInfo().NodeId + + ds.GoNode(nodeId, SubServiceDiscover, ¬ifyDiscover) } func (ds *OriginDiscoveryMaster) OnNodeDisconnect(nodeId string) {