Използваме flume и трябва да събера някои регистрационни съобщения в rabbitmq. Намерих източник имплементация, която чете съобщения от rabbitmq, но не можах да намеря приемник който може да пише съобщения в rabbit. Затова си мислех да напиша сам. Разглеждайки примерни реализации като logsandra, ме накара да мисля, че не би трябвало да е твърде трудно.
Въпреки това не можах да намеря никаква документация за това как да напиша персонализирана мивка. Не намерих maven repo за бурканите с канали или инструкции за настройка как да разположа персонализирана мивка.
Може ли някой да сподели опита си или по-добре да ме насочи към съществуващ урок.
