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

https://issues.apache.org/jira/browse/JCLOUDS-340