_send(self.target, msg_ctxt, msg,
wait_for_reply=True, timeout=timeout...，进入该类的_send() 方法
oslo_messaging/transport.py
def _send(self, target, ctxt, message, wait_for_reply..._driver.send(target, ctxt, message,
wait_for_reply=wait_for_reply,...在RabbitDriver 类中，send方法继承于基类AMQPDriverBase中的send()方法，最后调用了该基类的_send() 方法.
oslo_messaging/_drivers/amqpdriver.py...一句，发现ConnectionContext类并没有topic_send() 方法，实际上调用的还是impl_rabbit.py /Connection 类的方法。
云服务器
ICP备案
云直播
对象存储
腾讯会议
