diff --git a/cluster/dynamicdiscovery.go b/cluster/dynamicdiscovery.go index 82efab4..93f6f44 100644 --- a/cluster/dynamicdiscovery.go +++ b/cluster/dynamicdiscovery.go @@ -52,7 +52,7 @@ func (ds *DynamicDiscoveryMaster) addNodeInfo(nodeInfo *rpc.NodeInfo){ func (ds *DynamicDiscoveryMaster) OnInit() error{ ds.mapNodeInfo = make(map[int32] *rpc.NodeInfo,20) - ds.RegisterRpcListener(ds) + ds.RegRpcListener(ds) return nil } @@ -126,7 +126,7 @@ func (ds *DynamicDiscoveryMaster) RPC_RegServiceDiscover(req *rpc.ServiceDiscove } func (dc *DynamicDiscoveryClient) OnInit() error{ - dc.RegisterRpcListener(dc) + dc.RegRpcListener(dc) return nil } diff --git a/service/service.go b/service/service.go index 073aadb..352ac80 100644 --- a/service/service.go +++ b/service/service.go @@ -237,13 +237,13 @@ func (s *Service) OnRpcEvent(ev event.IEvent){ } } -func (s *Service) RegisterRpcListener (rpcEventLister rpc.IRpcListener) { +func (s *Service) RegRpcListener(rpcEventLister rpc.IRpcListener) { s.rpcEventLister = rpcEventLister s.RegEventReceiverFunc(event.Sys_Event_Rpc_Event,s.GetEventHandler(),s.OnRpcEvent) RegRpcEventFun(s.GetName()) } -func (s *Service) UnRegisterRpcListener (rpcLister rpc.IRpcListener) { +func (s *Service) UnRegRpcListener(rpcLister rpc.IRpcListener) { s.UnRegEventReceiverFunc(event.Sys_Event_Rpc_Event,s.GetEventHandler()) RegRpcEventFun(s.GetName()) }