summaryrefslogtreecommitdiff
path: root/sleekxmpp
diff options
context:
space:
mode:
authorCorrel Roush <correl@gmail.com>2011-10-03 14:32:48 -0400
committerCorrel Roush <correl@gmail.com>2011-10-03 14:32:48 -0400
commit3607c5b7924a33c99d584a2a20e940cab40dd76f (patch)
treede44279edcd8c92718a7553758a522bb7c11a3a0 /sleekxmpp
parente37adace62ee7bb8a29f661ac33853d94456d35f (diff)
downloadslixmpp-3607c5b7924a33c99d584a2a20e940cab40dd76f.tar.gz
slixmpp-3607c5b7924a33c99d584a2a20e940cab40dd76f.tar.bz2
slixmpp-3607c5b7924a33c99d584a2a20e940cab40dd76f.tar.xz
slixmpp-3607c5b7924a33c99d584a2a20e940cab40dd76f.zip
Make RPC events threaded
Allows, for example, an RPC service to make remote RPC calls with its own connection without blocking its own thread waiting for the result.
Diffstat (limited to 'sleekxmpp')
-rw-r--r--sleekxmpp/plugins/xep_0009/remote.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/sleekxmpp/plugins/xep_0009/remote.py b/sleekxmpp/plugins/xep_0009/remote.py
index b5d10b85..3cc0f520 100644
--- a/sleekxmpp/plugins/xep_0009/remote.py
+++ b/sleekxmpp/plugins/xep_0009/remote.py
@@ -699,10 +699,10 @@ class Remote(object):
with Remote._lock:
del cls._sessions[client.boundjid.bare]
result = RemoteSession(client, _session_close_callback)
- client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_method_call', result._on_jabber_rpc_method_call)
- client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_method_response', result._on_jabber_rpc_method_response)
- client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_method_fault', result._on_jabber_rpc_method_fault)
- client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_error', result._on_jabber_rpc_error)
+ client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_method_call', result._on_jabber_rpc_method_call, threaded=True)
+ client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_method_response', result._on_jabber_rpc_method_response, threaded=True)
+ client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_method_fault', result._on_jabber_rpc_method_fault, threaded=True)
+ client.plugin['xep_0009'].xmpp.add_event_handler('jabber_rpc_error', result._on_jabber_rpc_error, threaded=True)
if callback is None:
start_event_handler = result._notify
else: