Перевод PHP бэкенда на шину Redis streams и выбор независимой от фреймворков библиотеки

Прекрасный у Вас пример получился. Единственное, перечень используемых в системе сообщений «размазан» по нескольким слоям: упоминания встречаются как непосредственно в примерах (в consumer`ах), так и в конфигурации сервисов (config/container.php).

Вот если бы добавить функцию авторегистрации всех доступных сообщений в контейнер…