From eefcc682cce540c471aa8e49340f9f13ad54e9bf Mon Sep 17 00:00:00 2001 From: Stephen Mardson McQuay Date: Thu, 3 Mar 2011 00:03:52 -0700 Subject: [PATCH] added something to consume the service --- bin/results.py | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) create mode 100644 bin/results.py diff --git a/bin/results.py b/bin/results.py new file mode 100644 index 0000000..a647756 --- /dev/null +++ b/bin/results.py @@ -0,0 +1,19 @@ +#!/usr/bin/env python + +from multiprocessing.managers import BaseManager + +import numpy as np + +import interp.bootstrap + +class QueueManager(BaseManager): pass +QueueManager.register('get_outqueue') + +m = QueueManager(address=('gannon', 50000), authkey='asdf') +m.connect() + +if __name__ == '__main__': + outq = m.get_outqueue() + + while True: + print outq.get()