我正在尝试编写一种使用现有交换名称,新队列名称和路由键作为参数创建新队列的方法。交换的类型可能不同(直接,扇出,主题)。
是否有一种方法可以在不知道交换类型的情况下建立和绑定队列?
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()