examples/rpc_async.py

   1 #!/usr/bin/env python
   2 # -*- coding: utf-8 -*-
   3
   4 """
   5     Slixmpp: The Slick XMPP Library
   6     Copyright (C) 2011  Dann Martens
   7     This file is part of Slixmpp.
   8
   9     See the file LICENSE for copying permission.
  10 """
  11
  12 from slixmpp.plugins.xep_0009.remote import Endpoint, remote, Remote, \
  13     ANY_ALL, Future
  14 import time
  15
  16 class Boomerang(Endpoint):
  17
  18     def FQN(self):
  19         return 'boomerang'
  20
  21     @remote
  22     def throw(self):
  23         print "Duck!"
  24
  25
  26
  27 def main():
  28
  29     session = Remote.new_session('kangaroo@xmpp.org/rpc', '*****')
  30
  31     session.new_handler(ANY_ALL, Boomerang)
  32
  33     boomerang = session.new_proxy('kangaroo@xmpp.org/rpc', Boomerang)
  34
  35     callback = Future()
  36
  37     boomerang.async(callback).throw()
  38
  39     time.sleep(10)
  40
  41     session.close()
  42
  43
  44
  45 if __name__ == '__main__':
  46     main()
  47