Mercurial > libervia-pubsub
view sat_pubsub.tac @ 318:d13526c0eb32
RSM improvments/refactoring:
- a warning message is displayed if maxItems == 0 in getItems, and an empty list is returned in this case
- use the new container.ItemData instead of doing tuple (un)packing
- the list of ItemData => list of domish.Element conversion is done at the end of the workflow
- rsm request is checked in self._items_rsm directly
- better handling of Response.index in _items_rsm
- itemsIdentifiers can't be used with RSM (the later will be ignored if this happen)
- don't do approximative unpacking anymore in _items_rsm
- countItems and getIndex have been refactored and renamed getItemsCount and getItemsIndex, don't use query duplications anymore
- cleaned query handling in getItems
- /!\ mam module is temporarly broken
author | Goffi <goffi@goffi.org> |
---|---|
date | Sun, 03 Jan 2016 18:33:22 +0100 |
parents | 51af2ed8bd50 |
children |
line wrap: on
line source
#!/usr/bin/python #-*- coding: utf-8 -*- # Copyright (c) 2003-2008 Ralph Meijer # See LICENSE for details. """ Example TAC for SàT Pubsub. """ from twisted.application import service from twisted.words.protocols.jabber.jid import JID from sat_pubsub import tap application = service.Application("sat_pubsub") config = { 'jid': JID('sat-pubsub.necton3.int'), 'secret': 'pass', 'rhost': '127.0.0.1', 'rport': 5347, 'backend': 'pgsql', 'dbuser': 'goffi', 'dbpass': 'toto', 'dbname': "pubsub", 'dbhost': "localhost", 'dbport': None, 'verbose': True, 'hide-nodes': False, } idavollService = tap.makeService(config) idavollService.setServiceParent(application) # Set the maximum delay until trying to reconnect. componentService = idavollService.getServiceNamed('component') componentService.factory.maxdelay = 300