@Test
	public void testMqttSource() {
		String data = UUID.randomUUID().toString();
		stream(sources.mqtt() + XD_DELIMITER + sinks.file());
		sources.mqtt().ensureReady();
		sources.mqtt().sendData(data);
		assertValid(data, sinks.file());
		assertReceived(1);
	}
Verifies that data sent to a MQTT Broker can be retrieved by the mqtt source. The data retrieved by the broker is
then written to file, and the content of the file is verified against the original data set.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/MqttTest.java