messaging.py 文件源码

def __init__(self, host, port, consumer=None):
        """host: the hostname or IP address of the RPC server
           port: the port for the RPC server
           consumer: the consuming object for received messages"""
        self.host = host
        self.port = port
        self.consumer = consumer
        self.server = SimpleXMLRPCServer((host, port),
                                         logRequests=False,
                                         allow_none=True)
        self.server.register_function(self._client_send, "client_send")
        self.msg = None