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)
Find all L{LoggedAction} of the specified type.
dataset/ETHPy150Open retresco/Spyder/src/spyder/workerprocess.py/create_worker_management--crossover with--dataset/ETHPy150Open ClusterHQ/eliot/eliot/testing.py/LoggedAction.ofType