diff --git a/registry/directory/directory.go b/registry/directory/directory.go
index 960855bc3c322341823d8b61045a9abe5d299c4f..5d4a890c6e2f59107a1dff3fc09ebf2c37777d56 100644
--- a/registry/directory/directory.go
+++ b/registry/directory/directory.go
@@ -104,18 +104,8 @@ func (dir *RegistryDirectory) subscribe(url *common.URL) {
 }
 
 // Notify monitor changes from registry,and update the cacheServices
-func (dir *RegistryDirectory) Notify(event ...*registry.ServiceEvent) {
-	go dir.update(event...)
-}
-
-// update the cacheServices and subscribe service from registry
-func (dir *RegistryDirectory) update(events ...*registry.ServiceEvent) {
-	for _, event := range events {
-		logger.Debugf("registry update, result{%s}", event)
-		logger.Debugf("update service name: %s!", event.Service)
-	}
-
-	dir.refreshInvokers(events...)
+func (dir *RegistryDirectory) Notify(events ...*registry.ServiceEvent) {
+	go dir.refreshInvokers(events...)
 }
 
 // refreshInvokers refreshes service's events. It supports two modes: incremental mode and batch mode. If a single
@@ -140,6 +130,7 @@ func (dir *RegistryDirectory) refreshInvokers(events ...*registry.ServiceEvent)
 	}
 
 	for _, event := range events {
+		logger.Debugf("registry update, result{%s}", event)
 		if oldInvoker, _ := dir.cacheInvokerByEvent(event); oldInvoker != nil {
 			oldInvokers = append(oldInvokers, oldInvoker)
 		}