чем сложность: Мне нужно работать с двумя очередями. В одну залетают сообщения с внешки, обрабатываются и шлются сообщения во вторую очередь.
Для второй (внутренней очереди) все работает нормально, т.к. она задана как дефолтная в конфиге.
А когда подписываю обработчик на очередь с внешкой, то получаю ошибку:
[LogicException]
Got message without required parameter: "enqueue.processor_name"
Но фишка в том, что сообщения из внешки содержат только параметр enqueue.topic_name и не могут знать ничего о моем внутреннем обработчике.
Не юзал либу. У тебя скорее всего есть какая-то обёртка, registryProcessor или что-то около в либе. Попробуй для этой очереди задать свой процессор, мимо этой обёртки
Обсуждают сегодня