Add a high level API for consuming messages