public void sendBytes(byte[] bytes) {
		Socket socket = null;
		try {
			socket = new Socket(host, port);
			socket.getOutputStream().write(bytes);
		}
		catch (IOException ioException) {
			throw new IllegalStateException(ioException.getMessage(), ioException);
		}
		finally {
			if (socket != null) {
				try {
					socket.close();
				}
				catch (IOException ioException) {
					// no action required
				}
			}
		}
	}
Send the specified types to the host and and port of the TCP source.

@param bytes data to send
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/TcpSource.java