Mercurial > libervia-pubsub
annotate 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 |
| rev | line source |
|---|---|
| 230 | 1 #!/usr/bin/python |
| 2 #-*- coding: utf-8 -*- | |
| 3 # Copyright (c) 2003-2008 Ralph Meijer | |
| 4 # See LICENSE for details. | |
| 5 | |
| 6 """ | |
| 7 Example TAC for SàT Pubsub. | |
| 8 """ | |
| 9 | |
| 10 from twisted.application import service | |
| 11 from twisted.words.protocols.jabber.jid import JID | |
| 12 | |
|
234
51af2ed8bd50
replaced idavoll imports by sat_pubsub imports
Goffi <goffi@goffi.org>
parents:
230
diff
changeset
|
13 from sat_pubsub import tap |
| 230 | 14 |
| 15 application = service.Application("sat_pubsub") | |
| 16 | |
| 17 config = { | |
| 18 'jid': JID('sat-pubsub.necton3.int'), | |
| 19 'secret': 'pass', | |
| 20 'rhost': '127.0.0.1', | |
| 21 'rport': 5347, | |
| 22 'backend': 'pgsql', | |
| 23 'dbuser': 'goffi', | |
| 24 'dbpass': 'toto', | |
| 25 'dbname': "pubsub", | |
| 26 'dbhost': "localhost", | |
| 27 'dbport': None, | |
| 28 'verbose': True, | |
| 29 'hide-nodes': False, | |
| 30 } | |
| 31 | |
| 32 idavollService = tap.makeService(config) | |
| 33 idavollService.setServiceParent(application) | |
| 34 | |
| 35 # Set the maximum delay until trying to reconnect. | |
| 36 componentService = idavollService.getServiceNamed('component') | |
| 37 componentService.factory.maxdelay = 300 |