#NEWLINE# def _status_update_consumer( self , test ) : #NEWLINE# #INDENT# mq_url = ( 'memory://test_%s' % self ) #NEWLINE# manager = ( 'manager_%s' % test ) #NEWLINE# consumer = SimpleConsumer ( queue = 'status_update' , url = mq_url , manager = manager ) #NEWLINE# return consumer