def _cb_basic_cancel_notify(self, method):
        args = method.args
        consumer_tag = args.read_shortstr()
        callback = self._on_cancel(consumer_tag)
        if callback:
            callback(consumer_tag)
        else:
            raise ConsumerCancelled(consumer_tag, spec.Basic.Cancel)
Consumer cancelled by server.
dataset/ETHPy150Open veegee/amqpy/amqpy/channel.py/Channel._cb_basic_cancel_notify