zmqserver.py 文件源码

def __init__(self):
        self.pub_commands = {}
        self.worker_thread = None

        members = inspect.getmembers(self, predicate=inspect.ismethod)
        # print(members)

        for (func_name, func_handler) in members:
            if hasattr(func_handler, '__remote_yowsup__'):
                self.pub_commands[func_name] = {
                    "fn": func_handler,
                    "args": inspect.getargspec(func_handler)[0][1:]
                }
                print(self.pub_commands[func_name])

        self.worker_thread = ZmqServer(self.pub_commands)