Added support for using AMQP inside streaming.io v0.1.0
Updated to support new API