Implemented Exception propagation to the client
XD-443 Add MQTT Source

Parameters:

clientId (default 'xd.mqtt.client.id' from mqtt.properties)
topics (default 'xd.mqtt.test' from mqtt.properties)

See mqtt.properties for other properties such as broker
url.

To test:

Install RabbitMQ mqtt plugin

'mqtt | log'

Go to rabbit console, find queue 'mqtt-subscription-xd.mqtt.client.idqos1'
and publish a message to it.