Size: a a a

2021 May 31

AK

Anton K. in symfony
так как из exchange по routing_key будет попадать в разные очереди, то и консьюмеров надо плодить
источник

AK

Anton K. in symfony
на каждую очередь
источник

D

Dmitry in symfony
это как так ? я не понял
источник

AK

Anton K. in symfony
потому что консьюмер слушает определенную очередь, так?
источник

D

Dmitry in symfony
да, но кролик доставит по роутинг ключу в нужную очередь
источник

AK

Anton K. in symfony
вот в том и дело, что это ожидаемо, но работает не так, как ожидается
источник

AK

Anton K. in symfony
лично я ожидаю, что указав
rabbitmq:consumer tasks --routing-key="key1" буду получать все сообщения с ключом роута key1
источник

AD

Andrey Dembitskyi in symfony
Amqp работает иначе
источник

D

Dmitry in symfony
покажите настройки exchange для такого кейса
источник

AK

Anton K. in symfony
вот
источник

AK

Anton K. in symfony
источник

AK

Anton K. in symfony
вот продьюсер
источник

AK

Anton K. in symfony
источник

AK

Anton K. in symfony
вот консьюмер
источник

AK

Anton K. in symfony
вот этот конфиг значит, что будет слушать только очередь test-tasks. я понимаю, что это логично с точки зрения amqp
источник

AK

Anton K. in symfony
но фигня в том, что таких консьюмеров надо наплодить столько, сколько очередей
источник

D

Dmitry in symfony
а роутинг ключ в очереди вы не указываете ?
источник

D

Dmitry in symfony
туда же посыпется все что есть в exchange
источник

SP

Sergey Protko in symfony
да, один консюмер одна очередь. А ты как хотел?
источник

SP

Sergey Protko in symfony
ну то есть... один консюмер две очереди?
источник