changed impl by using xpub/xsub and zmq_proxy