Initial changes for AMQP transport driver
Not working yet