@Override
	protected String toDSL() {
		return "mqtt --url='tcp://" + host + ":" + port + "' --topics='xd.mqtt.test'";
	}
A test fixture that allows testing of the mqtt source module.

@author Glenn Renfro
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/MqttSource.java