diff --git a/registry/mock_registry.go b/registry/mock_registry.go
index d84b52945130ed82a90026b5ad9e1747afaac865..d1075539604e2c6e9be54853740714a73b83fac8 100644
--- a/registry/mock_registry.go
+++ b/registry/mock_registry.go
@@ -18,6 +18,7 @@
 package registry
 
 import (
+	"fmt"
 	"time"
 )
 
@@ -113,7 +114,9 @@ func (r *MockRegistry) Subscribe(url *common.URL, notifyListener NotifyListener)
 			for {
 				select {
 				case e := <-r.allAddress:
-					notifyListener.NotifyAll(e)
+					notifyListener.NotifyAll(e, func() {
+						fmt.Print("notify all ok")
+					})
 					break
 				}
 			}