Binding queue to exchange requires declaring exchange (creating exchange object) about aio-pika HOT 4 CLOSED

Let's imagine how should it works. Should I add some additional methods e.g. Queue.bind_by_name and Queue.unbind_by_name?

from aio-pika.

*_by_name() is fine.
Or break "Explicit is better than implicit" and have something like:

def bind(self, exchange: Union[str, Exchange],
         routing_key: str=None, *, arguments=None, timeout: int = None) -> asyncio.Future:
    ...
    exchange_name = exchange.name if isinstance(exchange, Exchange) else exchange
    self._channel.queue_bind(
        f.set_result,
        self.name,
        exchange_name,
        routing_key=routing_key,
        arguments=arguments
    )

from aio-pika.

I suggest not to add any additional methods or break anything - just change bind behavior: accept exchange name instead of exchange object like it is implemented in pika. Caller will have to use exchange.name and that's all.

from aio-pika.

@jkr78 your recipe implemented in 1.8.0. @decaz thank you for clarifying.

from aio-pika.