Make RabbitMQ Firehose resilient to broker deconnections

The `QueueingConsumer` builtin to RabbitMQ Java client is not suited for channel automatically recovered.