

def publish(self, jid_to, jid_from, node, payload):
    assert (self.xmlstream != None)
    pubmsg = PublishMessage(jid_to, jid_from, node)
    pubmsg.addPayload(payload)
    log.msg(('Publishing node(%s), msg(%s)' % (node, pubmsg.toXml())))
    self.xmlstream.send(pubmsg)

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