def create_worker_management(settings, zmq_context, io_loop):
    listening_socket = zmq_context.socket(zmq.SUB)
    listening_socket.setsockopt(zmq.SUBSCRIBE, "")
    listening_socket.connect(settings.ZEROMQ_MGMT_MASTER)

    publishing_socket = zmq_context.socket(zmq.PUB)
    publishing_socket.connect(settings.ZEROMQ_MGMT_WORKER)

    return ZmqMgmt(listening_socket, publishing_socket, io_loop=io_loop)
Create and return a new instance of the `ZmqMgmt`.
dataset/ETHPy150Open retresco/Spyder/src/spyder/workerprocess.py/create_worker_management