Updated the quickstart app to consume messages using the Rx API.