'When the broker cancels a consumer, delete it from our internal
dictionary.
:param pika.frame.Method method_frame: The method frame received'

def _on_cancel(self, method_frame):

    if (method_frame.method.consumer_tag in self._cancelled):
        return
    self._cleanup_consumer_ref(method_frame.method.consumer_tag)
