@beduin01

Почему у получателя в RabbitMQ нужно указывать имя очереди?

Изучаю примеры RabbitMQ. Вот мы создали exchange с типом fanout. К нему прибиндили очеред(ь\и).

Теперь по идее в получателе нам нужно указать только имя обменника и мы сможем получать данные из всех очередей т.к. тип fanout.

Однако в примере почему-то создается новая очередь со случайным именем. И в нее все получается. Где логика? Почему мы не можем просто получать данные из очередей созданных ранее?

Вот сам кусок кода получателя:
channel.exchange_declare(exchange='logs',
                         exchange_type='fanout')

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

channel.queue_bind(exchange='logs',
                   queue=queue_name)
  • Вопрос задан
  • 226 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы