def _basic_cancel_notify(self, args):
consumer_tag = args.read_shortstr()<EOL>callback = self._on_cancel(consumer_tag)<EOL>if callback:<EOL><INDENT>callback(consumer_tag)<EOL><DEDENT>else:<EOL><INDENT>raise ConsumerCancelled(consumer_tag, (<NUM_LIT>, <NUM_LIT:30>))<EOL><DEDENT>
Consumer cancelled by server.

        Most likely the queue was deleted.