@Test
	public void testHttpPostUtfText() throws InterruptedException, IOException {

		final HttpSource httpSource = newHttpSource();
		final FileSink fileSink = newFileSink().binary(true);

		/** I want to go to Japan. */
		final String stringToPostInJapanese = "\u65e5\u672c\u306b\u884c\u304d\u305f\u3044\u3002";

		final String streamName = generateStreamName();
		final String stream = String.format("%s | %s", httpSource, fileSink);

		logger.info("Creating Stream: " + stream);
		stream().create(streamName, stream);

		logger.info("Posting String: " + stringToPostInJapanese);
		httpSource.ensureReady().postData(stringToPostInJapanese);


		assertThat(fileSink, eventually(hasContentsThat(equalTo(stringToPostInJapanese))));

	}
This test will create a stream using a HTTP source and a File Sink. Subsequently the "http post" shell command is
used to post a UTF String (Japanese) to the admin server.
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractHttpCommandsTests.java