aio-pika RPC模式示例崩溃，并显示: RobustConnection: connection closed

import asyncio
import aio_pika

async def rpc_client():
    while True:
        try:
            connection = await aio_pika.connect_robust("amqp://guest:guest@localhost/")
            channel = await connection.channel()
            result = await channel.declare_queue("rpc_queue", exclusive=True)
            callback_queue = result.queue

            await channel.set_qos(prefetch_count=1)
            await channel.consume(callback_queue, on_message)

            print(" [x] Awaiting RPC requests")
            await asyncio.Future()  # run forever
        except aio_pika.exceptions.AMQPConnectionError:
            print("Connection lost, retrying in 5 seconds...")
            await asyncio.sleep(5)
        finally:
            if connection:
                await connection.close()

async def on_message(message: aio_pika.IncomingMessage):
    async with message.process():
        print(f" [.] Got {message.body}")
        # 这里处理请求并发送响应
        response = b"Response"
        await message.channel.default_exchange.publish(
            aio_pika.Message(body=response),
            routing_key=message.properties.reply_to,
            properties=aio_pika.BasicProperties(correlation_id=message.properties.correlation_id)
        )

if __name__ == "__main__":
    asyncio.run(rpc_client())