#NEWLINE# def make_exchange( self , name ) : #NEWLINE# #INDENT# task = asyncio . async ( self . channel . declare_exchange ( name , 'fanout' , durable = True , auto_delete = False , internal = False ) , loop = self . loop ) #NEWLINE# self . tick ( ) #NEWLINE# self . server . send_method ( self . channel . id , spec . ExchangeDeclareOK ( ) ) #NEWLINE# return task . result ( )