ich habe eine mbus instanz, die am ende eines Beispiels mittels
Code: Alles auswählen
mbus.loop()
Code: Alles auswählen
root=Tk()
root.title("blabla")
my_class = MyClass(root)
my_class.setModemAdresses(conf)
GUIFD = my_class
root.mainloop()
Code: Alles auswählen
mbus.loop()
Code: Alles auswählen
root=Tk()
root.title("blabla")
my_class = MyClass(root)
my_class.setModemAdresses(conf)
GUIFD = my_class
root.mainloop()
Code: Alles auswählen
from mbus import entity
from mbus import types
from mbus import guides
import logging
import notifier
def rel_one( adr, val, data = None ):
pass
def rpc_sum( adr, val, data = None ):
print "rpc_sum: incoming call from:",adr
print "building sum of:", val
res = 0
for i in val: res += i
# return None
# raise guides.RPCException( "failed" )
return guides.RPCReturn( [ res ],
descr = "the sum was calculated successfully" )
def newEntity( maddr ):
print "New Entity:", str( maddr )
def lostEntity( maddr ):
print "Lost Entity:", str( maddr )
def unknown( mmessage ):
print "received unknown message:"
print mmessage
def transporterror( e ):
print "Mbus transport error occured:", e
# logging
logging.getLogger().addHandler( logging.StreamHandler() )
#logging.getLogger().setLevel( logging.DEBUG )
# init notifier
notifier.init( notifier.GENERIC )
# create mbus entity
mbus = guides.Instance( "name:rpcsvr type:test lang:python" )
# register special callbacks (optional)
mbus.newEntityFunction = newEntity
mbus.lostEntityFunction = lostEntity
mbus.unknownMessageFunction = unknown
mbus.errorFunction = transporterror
mbus.addRPCCallback( "math.sum", rpc_sum )
mbus.addRPCCallback( "releas.one", rel_one )
try:
mbus.loop()
#except TypeError, e:
# print e
except types.MError, e:
print e.descr
print e.mmsg
except KeyboardInterrupt:
pass
Code: Alles auswählen
In [7]: sum([42, 23, 666])
Out[7]: 731