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()