使用不同的交换类型动态创建队列

问题描述 投票:0回答:1

我正在尝试编写一种使用现有交换名称,新队列名称和路由键作为参数创建新队列的方法。交换的类型可能不同(直接,扇出,主题)。

是否有一种方法可以在不知道交换类型的情况下建立和绑定队列?

def my_queue(self, exchange_name, queue_name, routing_key):
    with connection.acquire(block=True) as conn:
        ex = Exchange(exchange_name, type='topic')
        queue = Queue(name="my_queue", routing_key="my_key", exchange=ex)
        queue.maybe_bind(conn)
        queue.declare()
python rabbitmq celery amqp kombu
1个回答
0
投票
© www.soinside.com 2019 - 2024. All rights reserved.