
Untitled
By: a guest on
May 1st, 2012 | syntax:
None | size: 0.80 KB | hits: 12 | expires: Never
import sys
from twisted.internet import reactor
from twisted.python import log
from twisted.words.protocols.jabber.jid import JID
from wokkel import client, pubsub
jid_publisher = JID("user@host")
secret = "test123"
service = JID('pubsub.host')
nodeIdentifier = "/testNode"
log.startLogging(sys.stdout, setStdout=0)
factory = client.DeferredClientFactory(jid_publisher, secret)
factory.streamManager.logTraffic = True
ps = pubsub.PubSubClient()
ps.setHandlerParent(factory.streamManager)
# d = client.clientCreator(factory)
reactor.connectTCP('host', 5222, factory)
d = factory.deferred
d.addCallback(lambda _: ps.createNode(service, nodeIdentifier))
d.addCallback(lambda _: factory.streamManager.xmlstream.sendFooter())
d.addErrback(log.err)
d.addBoth(lambda _: reactor.callLater(1, reactor.stop))
reactor.run()