The create and stream methods in the Message API for OpenStack Marconi.