fix(General): use non-exclusive queue for streaming queues

2025-04-16 18:14:40 +08:00
parent 95d08686e0
commit 56bd0a3025
1 changed files with 1 additions and 1 deletions
@@ -130,7 +130,7 @@ async def convert_file_response(
        _channel = await connection.channel()
        exchange_name: str = AMQ_REPLY_TO_EXCHANGE
        _exchange = await _channel.get_exchange(name=exchange_name, ensure=True)
-        _queue = await _channel.declare_queue(exclusive=True)  # Declare a unique, exclusive queue
+        _queue = await _channel.declare_queue(exclusive=False)  # Declare a unique, non-exclusive queue
        _queue_name = _queue.name
        await _queue.bind(
            exchange=exchange_name,