|
|
@ -53,10 +53,16 @@ class Actor(Thread):
|
|
|
|
def post(self,**args):
|
|
|
|
def post(self,**args):
|
|
|
|
pass
|
|
|
|
pass
|
|
|
|
class Folders(Actor):
|
|
|
|
class Folders(Actor):
|
|
|
|
|
|
|
|
def init(self,config,item):
|
|
|
|
|
|
|
|
Actor.init(self,config,item)
|
|
|
|
|
|
|
|
self.config = config['folders']
|
|
|
|
|
|
|
|
self.item = item
|
|
|
|
def isvalid(self,item):
|
|
|
|
def isvalid(self,item):
|
|
|
|
print self.conf
|
|
|
|
print self.conf
|
|
|
|
def process(self,item):
|
|
|
|
def process(self,item):
|
|
|
|
print item
|
|
|
|
print item
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class Kill(Actor):
|
|
|
|
class Kill(Actor):
|
|
|
|
|
|
|
|
|
|
|
|
def isValid(self,item):
|
|
|
|
def isValid(self,item):
|
|
|
@ -182,8 +188,6 @@ class Orchestrator(Actor):
|
|
|
|
if 'content' in message :
|
|
|
|
if 'content' in message :
|
|
|
|
content = message['content']
|
|
|
|
content = message['content']
|
|
|
|
print self.actors
|
|
|
|
print self.actors
|
|
|
|
|
|
|
|
|
|
|
|
#sender = message['from']
|
|
|
|
|
|
|
|
to = message['to']
|
|
|
|
to = message['to']
|
|
|
|
if isinstance(content,basestring) and content.lower() in ['quit'] or to=='quit':
|
|
|
|
if isinstance(content,basestring) and content.lower() in ['quit'] or to=='quit':
|
|
|
|
if content.lower() == 'quit' or to == 'quit':
|
|
|
|
if content.lower() == 'quit' or to == 'quit':
|
|
|
|