xs.addObserver("/iq/pubsub/delete", self.result_delete_node)
xs.addObserver("/iq/query[@xmlns='http://jabber.org/protocol/disco#items']", self.result_discover)
xs.addObserver("/iq/pubsub/subscription[@subscription='subscribed']", self.result_subscribe_to_node)
- xs.addObserver("/iq/pubsub/configure", self.result_configure_node)
+ xs.addObserver("/iq/pubsub/configure/x", self.result_configure_node)
+ xs.addObserver("/iq/pubsub/configure/error", self.result_configure_node)
def __iq(self, t="get"):
iq = domish.Element((None, "iq"))
iq['from'] = self.id.full()
- iq['to'] = "pubsub.vplc27.inria.fr"
+ iq['to'] = "pubsub.%s" % self.id.host
iq['type'] = t
iq.addUniqueId()
return iq
if hook:
hook(iq)
self.delete_result_hook('configure')
+
self.requests.pop(iq['id'])
for i in iq.query.elements():
node = i['node']
if node.startswith(resource_prefix):
- self.command_que.put(self.delete_node, node)
+ self.command_queue.put((self.delete_node, node))
self.add_result_hook("discover", delete_slice_resources)
self.discover()
t = task.LoopingCall(slicemgr.flush_commands)
t.start(5.0) # check every 5 seconds
+
+ reactor.callLater(1, slicemgr.create_node, "/OMF")
+ reactor.callLater(1, slicemgr.create_node, "/OMF/SYSTEM")
+
reactor.connectTCP(slicemgr.id.host, 5222, slicemgr.factory)
reactor.listenTCP(5053, server.Site(slicemgr), interface="localhost")
reactor.run(installSignalHandlers=True)