Initial AMQP/json support