@Override
	protected String toDSL() {
		return "mqtt --url='tcp://" + host + ":" + port + "'";
	}
Test fixture that creates a mqtt sink.

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