public MqttSink mqtt() {
		return new MqttSink(environment.getAdminServerUrl().getHost(), 1883);
	}
Construct a new Mqttsink using the default RabbitMQ (MQTT-enbaled) broker host as specified in the environment.

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