(Boeing r1764)

added Broker.handlerawmsg() helper to invoke handlemsg() using packed bytes
This commit is contained in:
ahrenholz@gmail.com 2013-09-04 17:03:34 +00:00
parent cbda2f753b
commit 094131711b
2 changed files with 9 additions and 4 deletions

View file

@ -246,10 +246,7 @@ class Session(object):
except Exception, e:
self.warn("Error sending Event Message: %s" % e)
# also inform slave servers
coremsg = coreapi.CoreEventMessage(0,
msg[:coreapi.CoreMessage.hdrsiz],
msg[coreapi.CoreMessage.hdrsiz:])
tmp = self.broker.handlemsg(coremsg)
tmp = self.broker.handlerawmsg(msg)
return replies