ну да
но дорого это пересоздавть сообщения
и неэфективно не использовать иснтуременты очередей

типа в бесконечность чтоб не ушло

https://t.me/symfony_php/258181
?

для этого в осередях есть спец настройка которая отвечает за это
они все сами могут отправлять в DQL если было заданое количество потребелений и не было ACK
смысл это хачить рукми и делать то что уже сделано я не знаю

потому что это абстрация над кучей траспортов, вот видимо поэтому

не у всех такие настройки есть

Вопрос то в чем?
вы считаете что пересоздание сообщений в рэбите жто здравая идея?
Вметсо используовния инструментов рэбита

я не понимаю этого переобувания.
В одном сообщении "нельзя привязыватся на инфраструктуру", в другом "почему не использовать возможности инфраструктуры, иначе дорого"

в laravel сидят на очередях на redis потому что у них удобная админочка с UI для управления ею.

messenger тоже - милое поделие, что не пытается быть максимально эффективным, но удобным

не я в плане вы описали что надо экчанж использовать
Мы тогда обсуждали месадж бас
транспорт то да будет знать детали инфраструктуры
но месадж басу пофиг экчанж там не экчанж
прсото настройки баса должны при посредничестве транспорта переносится в инфраструктуру

А у messanger нет нстроек для роутинга по слушателю
Или по независмой обработке слушателей
тоесть транспорту нечего в exchange переводить

Я могу прокомментировать описанное вами решение выше так - зачем в приложении создавать N сообщений, если можно запушить в exchange одно сообщение, а брокер сам раскидает по очередям-подписчикам.

Но у каждого свои требования и решения проблемы.
Универсальные штуки не работают.

окей как мне это сделать через messenger?
ну и это не решает проблемы независимой обработки слушателей

что не решает?
На каждого слушателя по очереди - вот и независимость.

Мы уже нашли, что messenger не умеет в реальную независимость, только через свои клеймы.
Сам я им не пользуюсь, мне достаточно "bunny + свои 30 строк"

Я не вижу как предложенный вариант меняет поведение messenger коме того что сообщение начинает обработыватся не один раз а больше
Я вообще не понимаю зачем его обрабатывать больше одного раза в за счет копирования в разные очереди

ну например как у вас было...
Создался ивент - dispatch(СозданЗакан)
он ушел в excahnge -> оттуда в две очереди
- отправить смс
- отпавмть email

на каждую очередь независимый воркер.

смс отправили - ack
email нет. сделали retry - все равно нет. отправили в failed queue

далее нашли, что пароль сменили на почте, все исправили и делаем redelivery failed очереди. всем email пришел, ничего не потеряли

Всем привет. Кто может подсказать насчет обработчиков исключений?


Каким образом сделать свой обработчик исключений ErrorListener, в котором будет логика логирования этих исключений?
Необходимо, чтобы свой обработчик раскидывал различные Exception по различным уровням и добавлял дополнительную информацию для некоторых.

Если я просто зарегистрирую свой Listener в kernel.exception, который будет исключения по разным уровням отправлять,
то произойдёт дублирование логов, т.к. есть ещё Symfony листенер ErrorListener::logKernelException()

Как сделать так, чтобы лог был без дубликатов, а сообщения в лог попадали только из моего Listener'а, а не из Symfony?
Возможно ли как-то переопределить Symfony ErrorListener::logKernelException? Или нужно идти другим путём?

У нас message_bus занимает 30 строк?)

Просто не понятно сравнение, одно шина с транспортами, другое транспорт. Сравнение тёплого с мягким

Это отсылка на https://t.me/symfony_php/258253

На самом деле немного больше

@GDXbsv залез в код, он записывает какие хендлеры уже были успешно выполнены и при ретрае будет вызов только 1 неудачного из 10