diff --git a/bin/server.py b/bin/server.py new file mode 100644 index 0000000..cf24f05 --- /dev/null +++ b/bin/server.py @@ -0,0 +1,16 @@ +#!/usr/bin/env python + +from multiprocessing.managers import BaseManager +import Queue + +inqueue = Queue.Queue() +outqueue = Queue.Queue() +class QueueManager(BaseManager): + pass +QueueManager.register('get_inqueue', callable=lambda:inqueue) +QueueManager.register('get_outqueue', callable=lambda:outqueue) + + +m = QueueManager(address=('', 50000), authkey='asdf') +s = m.get_server() +s.serve_forever()