public MqttSource mqtt() {
		return new MqttSource(xdEnvironment.getRabbitMQHost());
	}
Construct a new MqttSource using the default RabbitMQ (MQTT-enbaled) broker host as specified in the
environment.

@return a mqtt source
spring-xd-integration-test/src/main/java/org/springframework/xd/integration/fixtures/Sources.java