#NEWLINE# def _setup_mgmt_sockets( self ) : #NEWLINE# #INDENT# self . _mgmt_sockets = dict ( ) #NEWLINE# mgmt_master_worker = 'inproc://master/worker/coordination/' #NEWLINE# sock = self . _ctx . socket ( zmq . PUB ) #NEWLINE# sock . bind ( mgmt_master_worker ) #NEWLINE# self . _mgmt_sockets [ 'tmp1' ] = sock #NEWLINE# self . _mgmt_sockets [ 'master_pub' ] = ZMQStream ( sock , self . _io_loop ) #NEWLINE# self . _mgmt_sockets [ 'worker_sub' ] = self . _ctx . socket ( zmq . SUB ) #NEWLINE# self . _mgmt_sockets [ 'worker_sub' ] . setsockopt ( zmq . SUBSCRIBE , '' ) #NEWLINE# self . _mgmt_sockets [ 'worker_sub' ] . connect ( mgmt_master_worker ) #NEWLINE# mgmt_worker_master = 'inproc://worker/master/coordination/' #NEWLINE# self . _mgmt_sockets [ 'worker_pub' ] = self . _ctx . socket ( zmq . PUB ) #NEWLINE# self . _mgmt_sockets [ 'worker_pub' ] . bind ( mgmt_worker_master ) #NEWLINE# sock = self . _ctx . socket ( zmq . SUB ) #NEWLINE# sock . setsockopt ( zmq . SUBSCRIBE , '' ) #NEWLINE# sock . connect ( mgmt_worker_master ) #NEWLINE# self . _mgmt_sockets [ 'tmp2' ] = sock #NEWLINE# self . _mgmt_sockets [ 'master_sub' ] = ZMQStream ( self , self . _io_loop )