#NEWLINE# def manager( ) : #NEWLINE# #INDENT# command_queue = Queue ( ) #NEWLINE# consumer_queue = Queue ( ) #NEWLINE# w = ManagerProcess ( s ) #NEWLINE# w . start ( ) #NEWLINE# QueueManager . register ( WRITER_QUEUE , callable = ( lambda : command_queue ) ) #NEWLINE# QueueManager . register ( READER_QUEUE , callable = ( lambda : consumer_queue ) ) #NEWLINE# m = QueueManager ( address = ( '' , CONTROL_PORT ) , authkey = CONTROL_KEY ) #NEWLINE# s = m . get_server ( ) #NEWLINE# s . serve_forever ( )