Skip to content
Snippets Groups Projects
Commit 7ff81571 authored by fangyincheng's avatar fangyincheng
Browse files

Merge remote-tracking branch 'upstream/develop' into develop

parents 6b0dfdac cb872d96
No related branches found
No related tags found
No related merge requests found
package registry
import "github.com/dubbo/go-for-apache-dubbo/config"
type RegistryFactory interface {
GetRegistry(url config.URL) Registry
}
......@@ -14,13 +14,6 @@ type Registry interface {
//used for service consumer ,start subscribe service event from registry
Subscribe(config.URL) (Listener, error)
//input the serviceConfig , registry should return serviceUrlArray with multi location(provider nodes) available
//GetService(SubURL) ([]SubURL, error)
//close the registry for Elegant closing
//Close()
//return if the registry is closed for consumer subscribing
//IsClosed() bool
}
type Listener interface {
......
......@@ -294,8 +294,8 @@ func (z *zookeeperClient) RegisterTemp(basePath string, node string) (string, er
tmpPath, err = z.conn.Create(zkPath, data, zk.FlagEphemeral, zk.WorldACL(zk.PermAll))
}
z.Unlock()
//if err != nil && err != zk.ErrNodeExists {
if err != nil {
if err != nil && err != zk.ErrNodeExists {
//if err != nil {
log.Warn("conn.Create(\"%s\", zk.FlagEphemeral) = error(%v)\n", zkPath, jerrors.ErrorStack(err))
return "", jerrors.Trace(err)
}
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment