#NEWLINE# def _recv_cancel_ok( self , method_frame ) : #NEWLINE# #INDENT# consumer_tag = method_frame . args . read_shortstr ( ) #NEWLINE# self . _purge_consumer_by_tag ( consumer_tag ) #NEWLINE# cb = self . _cancel_cb . popleft ( ) #NEWLINE# if cb : #NEWLINE# #INDENT# cb ( )