

def startService(self):
    a = client.BasicAuthenticator(self.jid, self.pwd)
    self.factory = xmlstream.XmlStreamFactory(a)
    self.factory.protocol = XmlStreamJabber
    self.factory.client = self
    self.factory.addBootstrap(xmlstream.STREAM_AUTHD_EVENT, self.clientAuth)
    self.addObserver('/message', self.gotMessage)
    self.addObserver('/iq', self.gotIq)
    self.service = internet.TCPClient(self.host, self.port, self.factory)
    self.service.startService()

dataset/ETHPy150Open selfsk/nodeset.core/src/nodeset/core/pubsub/agent.py XmppAgent.startService/original