examples/rpc_async.py

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