[文档]defqos_global(self,c)->bool:"""Determine if global QoS should be applied. Additional information: https://www.rabbitmq.com/docs/consumer-prefetch https://www.rabbitmq.com/docs/quorum-queues#global-qos """# - RabbitMQ 3.3 completely redefines how basic_qos works...# This will detect if the new qos semantics is in effect,# and if so make sure the 'apply_global' flag is set on qos updates.qos_global=notc.connection.qos_semantics_matches_specifc.app.conf.worker_detect_quorum_queues:using_quorum_queues,qname=detect_quorum_queues(c.app,c.connection.transport.driver_type)ifusing_quorum_queues:qos_global=Falselogger.info("Global QoS is disabled. Prefetch count in now static.")returnqos_global