diff options
| author | Correl Roush <correl@gmail.com> | 2011-10-03 14:32:48 -0400 |
|---|---|---|
| committer | Correl Roush <correl@gmail.com> | 2011-10-03 14:32:48 -0400 |
| commit | 3607c5b7924a33c99d584a2a20e940cab40dd76f (patch) | |
| tree | de44279edcd8c92718a7553758a522bb7c11a3a0 /sleekxmpp | |
| parent | e37adace62ee7bb8a29f661ac33853d94456d35f (diff) | |
| download | slixmpp-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.py | 8 |
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: |