def _start_mpbs_broker(self):
'''
Multi-Publisher-Multi-Subscriber
'''
context = zmq.Context()
front = context.socket(zmq.SUB) # @UndefinedVariable
front.setsockopt(zmq.SUBSCRIBE, b"") # @UndefinedVariable
front.bind(self.frontend)
back = context.socket(zmq.PUB) # @UndefinedVariable
back.bind(self.backend)
zmq.proxy(front, back) # @UndefinedVariable
评论列表
文章目录