SpringSource/spring-xd — pull request #109 by garyrussell (2013-07-11 15:57:28+00:00)
Title: 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.