@Test
	public void testTCPSink() {
		String data = UUID.randomUUID().toString();
		stream(sources.tcp() + XD_DELIMITER + sinks.file());
		stream("dataSender",
				"trigger --payload='" + data + "'" + XD_DELIMITER + sinks.tcpSink());
		assertValid(data, sinks.file());
		assertReceived(1);
	}
* Verifies that data sent by the TCP sink that terminates with a CRLF works as expected.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/TcpTest.java