Streaming interface to rabbitmq queues