Messaging model changes and MQTT integration

Please review and merge