#NEWLINE# def setup( self ) : #NEWLINE# #INDENT# if ( not channel . abstract ) : #NEWLINE# #INDENT# self . connection = Connection ( transport = 'memory' ) #NEWLINE# with self . connection . channel ( ) as channel : #NEWLINE# #INDENT# channel . exchange_declare ( 'amq.direct' ) #NEWLINE# #UNINDENT# self . q = self . Queue ( None , no_ack = True )