my_server.py

from multiprocessing.managers import BaseManager
import queue
import sys


class QueueManager(BaseManager):
    pass


ip = sys.argv[1] if len(sys.argv) > 1 else 'localhost'
port = int(sys.argv[2]) if len(sys.argv) > 2 else 50000

in_queue = queue.Queue()
out_queue = queue.Queue()
QueueManager.register('in_queue', callable=lambda:in_queue)
QueueManager.register('out_queue', callable=lambda:out_queue)
manager = QueueManager(address=(ip, int(port)), authkey='blah'.encode())
server = manager.get_server()
server.serve_forever()