high-level consumer for a single message stream