修改变量名和排版
diff --git a/dubbo_client/registry.py b/dubbo_client/registry.py
index d64be6e..7c86e5f 100644
--- a/dubbo_client/registry.py
+++ b/dubbo_client/registry.py
@@ -1,13 +1,10 @@
# coding=utf-8
-import urllib
-
-from kazoo.protocol.states import KazooState
-
-from dubbo_client.common import ServiceProvider
-
__author__ = 'caozupeng'
+import urllib
+from kazoo.protocol.states import KazooState
from kazoo.client import KazooClient
+from dubbo_client.common import ServiceProvider
class Registry(object):
@@ -38,8 +35,8 @@
__service_provides = {}
__connect_state = 'UNCONNECT'
- def __init__(self, hosts):
- self.__zk = KazooClient(hosts=hosts, read_only=True)
+ def __init__(self, zk_hosts):
+ self.__zk = KazooClient(hosts=zk_hosts, read_only=True)
self.__zk.add_listener(self.__state_listener)
self.__zk.start()
@@ -57,6 +54,11 @@
self.__connect_state = state
def __event_listener(self, event):
+ """
+ node provides上下线的监听回调函数
+ :param event:
+ :return:
+ """
self.__do_event(event)
def __handler_urls(self, urls):
diff --git a/test_dubbo_client/test_rpclib.py b/test_dubbo_client/test_rpclib.py
index 553dce9..61f4a25 100644
--- a/test_dubbo_client/test_rpclib.py
+++ b/test_dubbo_client/test_rpclib.py
@@ -20,6 +20,6 @@
print dubbo_client.isLimit('MAN', 'Joe')
print dubbo_client('getUser', 'A005')
- except DubboClientError, client_e:
- print client_e
+ except DubboClientError, client_error:
+ print client_error
time.sleep(5)
