#NEWLINE# def _cb_basic_cancel_notify( self , method ) : #NEWLINE# #INDENT# 'Consumer cancelled by server.\n\n        Most likely the queue was deleted.\n        ' #NEWLINE# args = method . args #NEWLINE# consumer_tag = args . read_shortstr ( ) #NEWLINE# callback = self . _on_cancel ( consumer_tag ) #NEWLINE# if callback : #NEWLINE# #INDENT# callback ( consumer_tag ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise ConsumerCancelled ( consumer_tag , spec . Basic . Cancel )