How can I subscribe to a queue without using a decorator?

[YanNezamutdinov]

The microservice accepts a list of queue names. I create instances of the class, where I pass the name of the queue that I want to listen to.

I don't know exactly how to properly organize a connection to rabbitmq, inside a class, or transfer connect to an instance of the class, and I don't quite understand how to subscribe to a queue without a decorator?

Each microservice must subscribe to 10-100 queues.

[Lancetnik]

Sure, you can use router with explicit routes if you want: https://faststream.airt.ai/latest/getting-started/routers/#delay-handler-registration

[Lancetnik]

Broker should already connected to be able to setup subscriber. I have to add a new error message. Anyway, you are trying to make something strange and the framework was not designed for such usage. What's your case?

[YanNezamutdinov]

This is a microservice project. One of the services is waiting for a message with a set of queues to which it needs to connect and process the messages that arrive there. Sometimes you need to change the set of listening queues.

[Lancetnik]

Well, you can take a look here: this is the correct usage of dynamic subscibers: https://github.com/airtai/fastagency/blob/main/examples/nats/faststream_backend.py#L50

P.S. you should use already running broker to setup them, but register via router or any other broker

[YanNezamutdinov]

Yes, that's about what I did. But it's still difficult for me to understand the idea of inheriting brokers, probably because I'm new here. Is it a good idea to declare a broker broker = NatsBroker("nats://nats-fastagency:4222") outside of a function every time it is needed?

[Lancetnik]

Nope, broker should be the single instance in your app. It is important to use already running broker for all operations. You have all possibilities to do any you want without a new broker creation