First version of a RabbitMQ Firehose implementation.