Есть некий rabbitmq который в себе собирает сообщения от сервисов, в него они попадают не по формату headers - body, а имеют только body
В результате когда мы вызываем php bin/console messenger:consume -vv rest_uploader, чтобы просто прочитать очередь, стандартные serializer не обрабатывают эти сообщения. А падают с exception. В одном сдучае если использовать PHPSerializer, ругается на то что не может json обработать. А стандартный symfony serializer, ругается что нет заголовков которые внутри у него обрабатываются.
В результате вроде как можно реализовать кастомный сериализатор. Класс который наследует SerializerInterface. У него там два метода decode и encode. И все ничего, но он требует реализации encode который в свою очередь всегда пересылает сообщения в реббит. А МНЕ НУЖНО ПРОСТО ПРОЧИТАТЬ ОЧЕРЕДЬ И СДЕЛАТЬ ЛОГИКУ(дополнительную).