diff options
Diffstat (limited to 'examples/rpc_server_side.py')
| -rwxr-xr-x[-rw-r--r--] | examples/rpc_server_side.py | 31 |
1 files changed, 17 insertions, 14 deletions
diff --git a/examples/rpc_server_side.py b/examples/rpc_server_side.py index d1a11c17..9e8b48d6 100644..100755 --- a/examples/rpc_server_side.py +++ b/examples/rpc_server_side.py @@ -1,3 +1,6 @@ +#!/usr/bin/env python +# -*- coding: utf-8 -*- + """ SleekXMPP: The Sleek XMPP Library Copyright (C) 2011 Dann Martens @@ -11,42 +14,42 @@ from sleekxmpp.plugins.xep_0009.remote import Endpoint, remote, Remote, \ import threading class Thermostat(Endpoint): - + def FQN(self): return 'thermostat' - + def __init__(self, initial_temperature): self._temperature = initial_temperature - self._event = threading.Event() - + self._event = threading.Event() + @remote def set_temperature(self, temperature): print("Setting temperature to %s" % temperature) self._temperature = temperature - + @remote def get_temperature(self): return self._temperature @remote(False) def release(self): - self._event.set() - + self._event.set() + def wait_for_release(self): - self._event.wait() - + self._event.wait() + def main(): session = Remote.new_session('sleek@xmpp.org/rpc', '*****') - + thermostat = session.new_handler(ANY_ALL, Thermostat, 18) - + thermostat.wait_for_release() - + session.close() - + if __name__ == '__main__': main() - + |