diff --git a/registry/etcdv3/registry.go b/registry/etcdv3/registry.go index ed310bddfeea90f24bd47414bd34277f3160dd1b..5d389c36374fe9de5561418bc90d44a7d780fd48 100644 --- a/registry/etcdv3/registry.go +++ b/registry/etcdv3/registry.go @@ -164,7 +164,7 @@ func (r *etcdV3Registry) DoSubscribe(svc *common.URL) (registry.Listener, error) //register the svc to dataListener r.dataListener.AddInterestedURL(svc) - go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.PROVIDER_PROTOCOL, svc.Service()), r.dataListener) + go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.DEFAULT_CATEGORY, svc.Service()), r.dataListener) return configListener, nil } diff --git a/registry/kubernetes/registry.go b/registry/kubernetes/registry.go index ddb2ce8379e314cecbf1a193a31eab4649b25012..8a02d0e3e693b58946a97e7b47238e0be4272dcf 100644 --- a/registry/kubernetes/registry.go +++ b/registry/kubernetes/registry.go @@ -134,7 +134,7 @@ func (r *kubernetesRegistry) DoSubscribe(svc *common.URL) (registry.Listener, er //register the svc to dataListener r.dataListener.AddInterestedURL(svc) - go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.PROVIDER_PROTOCOL, svc.Service()), r.dataListener) + go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.DEFAULT_CATEGORY, svc.Service()), r.dataListener) return configListener, nil } diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go index 21d0f49a2d3fa1d149f36e7aae18a8ababc57c12..4fd58e9e4d9ecd285675fc416f3d7a36bf19fd54 100644 --- a/registry/zookeeper/registry.go +++ b/registry/zookeeper/registry.go @@ -216,7 +216,7 @@ func (r *zkRegistry) getListener(conf *common.URL) (*RegistryConfigurationListen //Interested register to dataconfig. r.dataListener.AddInterestedURL(conf) - go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.PROVIDER_PROTOCOL, url.QueryEscape(conf.Service())), r.dataListener) + go r.listener.ListenServiceEvent(fmt.Sprintf("/dubbo/%s/"+constant.DEFAULT_CATEGORY, url.QueryEscape(conf.Service())), r.dataListener) return zkListener, nil }