Mercurial > libervia-pubsub
annotate sat_pubsub.tac @ 291:61fb4817b77f
delegation: iq forwarded management:
in addition to the onForward observer, the xmlstream.send message is monkey patched, so we can inject the forwarded stanza as if it was received normally, and intercept the result to send it back to the server.
author | Goffi <goffi@goffi.org> |
---|---|
date | Mon, 04 May 2015 18:40:47 +0200 |
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 |