|
|
@ -181,6 +181,7 @@ class Orchestrator(Actor):
|
|
|
|
message = json.loads(stream)
|
|
|
|
message = json.loads(stream)
|
|
|
|
if 'content' in message :
|
|
|
|
if 'content' in message :
|
|
|
|
content = message['content']
|
|
|
|
content = message['content']
|
|
|
|
|
|
|
|
print self.actors
|
|
|
|
|
|
|
|
|
|
|
|
#sender = message['from']
|
|
|
|
#sender = message['from']
|
|
|
|
to = message['to']
|
|
|
|
to = message['to']
|
|
|
@ -189,6 +190,7 @@ class Orchestrator(Actor):
|
|
|
|
print '**** closing ',self.getIdentifier()
|
|
|
|
print '**** closing ',self.getIdentifier()
|
|
|
|
channel.close()
|
|
|
|
channel.close()
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
|
|
|
|
|
|
|
|
id = to.lower()
|
|
|
|
id = to.lower()
|
|
|
|
actor = self.actors[id]
|
|
|
|
actor = self.actors[id]
|
|
|
|
|
|
|
|
|
|
|
|