broker.py 文件源码

def _start_mrer_broker(self):
        '''
        Multi-Req-Mutli-Rep
        '''

        zc = zmq.Context()

        front = zc.socket(zmq.ROUTER)  # @UndefinedVariable
        front.bind(self.frontend)

        back = zc.socket(zmq.DEALER)  # @UndefinedVariable
        back.bind(self.backend)

        zmq.proxy(front, back)  # @UndefinedVariable