def _start_mpup_broker(self):
'''
Multi-Pusher-Mutli-Puller
'''
context = zmq.Context()
front = context.socket(zmq.PULL) # @UndefinedVariable
front.bind(self.frontend)
back = context.socket(zmq.PUSH) # @UndefinedVariable
back.bind(self.backend)
zmq.proxy(front, back) # @UndefinedVariable
评论列表
文章目录