#NEWLINE# def send_request( self , payload ) : #NEWLINE# #INDENT# message = Message . create ( self . channel , payload ) #NEWLINE# message . reply_to = self . callback_queue #NEWLINE# self . queue [ message . correlation_id ] = None #NEWLINE# message . publish ( routing_key = self . rpc_queue ) #NEWLINE# return message . correlation_id