

def subscribe(self, jid_to, node):
    assert (self.xmlstream != None)
    submsg = SubscribeMessage(jid_to, self.jid.userhost(), node)
    log.msg(('Subscribing to node(%s), msg(%s)' % (node, submsg.toXml())))
    self.xmlstream.send(submsg)

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