Fixes #8 Add support for rabbitmq
Extract code that waits for topic leader and improve error reference