def _check_queue_in_qos(self, qos_id, qos_queue):
        if qos_id != qos_queue.qos_id:
            raise ext_qos.QosQueueNotInQos(
                qos_id=qos_id,
                qos_queue_id=qos_queue.qos_id
            )