было, а сейчас что-то туплю
для определенных сообщений нужна своя стратегия повторов, создаю новый транспорт, настраиваю, на нужные сообщения вешаю интерфейс, по которому оно будет роутится на мой новый транспорт
запускаю свое новое событие (которое с SecondMessageInterface), а оно обрабатывается в старом транспорте, новый просто игнорит
конфиг такой:
framework:
messenger:
failure_transport: failed
first:
dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
retry_strategy:
max_retries: 3
delay: 30000
multiplier: 1
second:
dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
retry_strategy:
max_retries: 30
delay: 20000
multiplier: 2
failed: 'doctrine://default?queue_name=failed'
routing:
App\FirstMessageInterface: first
App\SecondMessageInterface: second
консумеры запускаются так, крутятся оба, ничего не перепутал, тут все точно ок
bin/console messenger:consume --limit=10 first >&1;
bin/console messenger:consume --limit=10 second >&1;
что может быть не так?
Тут одна и та же очередь для разных транспортов, все сообщения попадают в нее
Обсуждают сегодня