Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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()
Advertisement
Add Comment
Please, Sign In to add comment