source: ralphm-patches/pubsub_client_example.patch @ 56:fa1511cccfe2

# HG changeset patch
# Parent bbb746f7971831cb09e1539bfd3fefe862c3cc9e

diff -r bbb746f79718 doc/examples/pubsub_client_create_node.tac
--- /dev/null   Thu Jan 01 00:00:00 1970 +0000
+++ b/doc/examples/pubsub_client_create_node.tac        Mon Nov 21 23:14:09 2011 +0100
@@ -0,0 +1,56 @@
+"""
+An XMPP Publish Subscribe publisher client as an XMPP client.
+
+This client logs in as C{publisher@example.org}, creates a node at
+C{pubsub.example.org} and prints the node identifier.
+
+Note that some services may change the node identifier to adhere to local
+policies. If you set L{NODE_IDENTIFIER} to C{None}, the service will create an
+'instant node', with a unique node identifier.
+"""
+
+from twisted.application import service
+from twisted.internet import reactor, task
+from twisted.python import log
+from twisted.words.protocols.jabber.jid import JID
+from wokkel.client import XMPPClient
+from wokkel.pubsub import PubSubClient
+
+# Configuration parameters
+
+THIS_JID = JID('publisher@example.org')
+SERVICE_JID = JID('pubsub.example.org')
+NODE_IDENTIFIER = 'test_node'
+SECRET = 'secret'
+LOG_TRAFFIC = True
+
+class Publisher(PubSubClient):
+
+    count = None
+    loopingCall = None
+    nodeIdentifier = None
+
+    def connectionInitialized(self):
+        def cb(nodeIdentifier):
+            log.msg("The node %r was successfully created" % nodeIdentifier)
+        d = self.createNode(SERVICE_JID, NODE_IDENTIFIER)
+        d.addCallbacks(cb, log.err)
+        d.addCallback(lambda _: reactor.stop())
+
+
+    def nodeCreated(self, nodeIdentifier):
+        self.nodeIdentifier = nodeIdentifier
+        self.count = 0
+        self.loopingCall = task.LoopingCall(self.doPublish)
+        self.loopingCall.start(5)
+
+# Set up the Twisted application
+
+application = service.Application("Publish Subscribe publisher")
+
+client = XMPPClient(THIS_JID, SECRET)
+client.logTraffic = LOG_TRAFFIC
+client.setServiceParent(application)
+
+pubsubHandler = PubSubClient()
+pubsubHandler.setHandlerParent(client)