Проверить привязку очереди ответов

[Vovaman]

Код app_svc.py:

async def _amqp_connect(self) -> None:
        await super()._amqp_connect()

        self._callback_queue = await self._amqp_channel.declare_queue(
            durable=True, exclusive=True
        )
        await self._callback_queue.bind(
            exchange=self._amqp_publish["main"]["exchange"],
            routing_key=self._callback_queue.name
        )

        await self._callback_queue.consume(self._on_rpc_response, no_ack=True)

получается, что одна очередь ответов на все экземпляры сервиса, что неправильно

[Vovaman]

Не ошибка. Очередь создается с уникальным именем:

async def _amqp_connect(self) -> None:
        await super()._amqp_connect()

        self._callback_queue = await self._amqp_channel.declare_queue(
            durable=True, exclusive=True
        )
        await self._callback_queue.bind(
            exchange=self._amqp_publish["main"]["exchange"],
            routing_key=self._callback_queue.name
        )

        await self._callback_queue.consume(self._on_rpc_response, no_ack=True)