diff -r 62213a34726e -r f02139297beb zmqclient.py --- a/zmqclient.py Mon Jan 21 18:01:25 2013 +0100 +++ b/zmqclient.py Tue Jan 22 18:16:20 2013 +0100 @@ -23,6 +23,7 @@ from functools import partial import zmq +from cubicweb.server.cwzmq import cwproto_to_zmqaddr # XXX hack to overpass old zmq limitation that force to have # only one context per python process @@ -33,9 +34,9 @@ class ZMQRepositoryClient(object): """ - This class delegate the overall repository stuff to a remote source. + This class delegates the overall repository stuff to a remote source. - So calling a method of this repository will results on calling the + So calling a method of this repository will result on calling the corresponding method of the remote source repository. Any raised exception on the remote source is propagated locally. @@ -44,8 +45,13 @@ """ def __init__(self, zmq_address): + """A zmq address provided here will be like + `zmqpickle-tcp://127.0.0.1:42000`. W + + We chop the prefix to get a real zmq address. + """ self.socket = ctx.socket(zmq.REQ) - self.socket.connect(zmq_address) + self.socket.connect(cwproto_to_zmqaddr(zmq_address)) def __zmqcall__(self, name, *args, **kwargs): self.socket.send_pyobj([name, args, kwargs])