def __init__(self, socket_addr=_DEFAULT_IPC):
super(DistributedRegistry, self).__init__()<EOL>self.stats = dict()<EOL>self.socket_addr = socket_addr<EOL>self.zmq_context = None<EOL>self.socket = None<EOL>
:param socket_addr: the 0MQ IPC socket address; has to be the same as corresponding aggregator's