Moving to high-level api to consume and get messages