diff --git a/bin/interactq.py b/bin/interactq.py new file mode 100644 index 0000000..a448799 --- /dev/null +++ b/bin/interactq.py @@ -0,0 +1,10 @@ +import interp.bootstrap +from multiprocessing.managers import BaseManager +class QueueManager(BaseManager): pass +QueueManager.register('get_inqueue' ) +QueueManager.register('get_outqueue') +m = QueueManager(address=('localhost', 6666), authkey='asdf') +m.connect() +m.get_outqueue() +oq = m.get_outqueue() +iq = m.get_inqueue()