@Test
	public void testMqttSink() {
		String data = UUID.randomUUID().toString();
		stream(sources.mqtt() + XD_DELIMITER + sinks.file());
		sources.mqtt().ensureReady();
		stream("mqttSender", "trigger --payload='" + data + "'" + XD_DELIMITER + sinks.mqtt());
		assertValid(data, sinks.file());
		assertReceived(1);

	}
Verifies that the data sent from a MQTT Sink was received by a broker. This method utilizes mqttsource to
retrieve data from the broker. This data 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