How can I obtain the length of the specified RabbitMQ message queue test?

[willnufe]

Hi, i'm using RabbitRouter.
How can I obtain the length of the specified RabbitMQ message queue test?

from faststream.rabbit.fastapi import RabbitRouter
from pydantic import BaseModel
from fastapi import FastAPI, Request, BackgroundTasks, Depends
from contextlib import asynccontextmanager

@asynccontextmanager
async def lifespan(app: FastAPI):
    ...
    yield
    ...

router = RabbitRouter(rabbit_url, lifespan=lifespan, log_level=3)
app = FastAPI()


class Message(BaseModel):
    file_id: str
    session_id: str
    url: str

@router.post("/behavior/asr/")
async def generate(raw_request: Request):

    request_dict = await raw_request.json()

    file_id = request_dict['source']['image_uuid']
    session_id = request_dict['session']['session_id']
    url = request_dict['response_route']['url']


    ret = {
        'file_id': file_id,
        'session_id': session_id,
        'url': url
    }
    # TODO  How can I obtain the length of the specified RabbitMQ message queue `test`?

    await router.broker.publish(Message(**ret), "test")

    return 

app.include_router(router)

if __name__ == "__main__":

    uvicorn.run(
        "__main__:app",
        host='0.0.0.0',
        port=8080,
        workers=4,
        limit_concurrency=10,
        reload=False
    )

[Lancetnik]

@willnufe RabbitMQ returns actual message count only in declraration frame, so use should get and save somewhere real queue object by broker.declare_queue and ask for declaration frame when you need such information

Just a little code snippet:

from faststream import FastStream
from faststream.rabbit import RabbitBroker, RabbitQueue

broker = RabbitBroker()
app = FastStream(broker)

@broker.subscriber("test-queue")
async def handler(msg): ...

@app.after_startup
async def t():
    # get queue object
    queue_obj = await broker.declare_queue(RabbitQueue("test-queue", passive=True))
    # ask for declaration frame
    declare_frame = await queue_obj.declare()
    actual_message_count = declare_frame.message_count
    print(actual_message_count)