@Test
	public void testAggregatorNormalRelease() throws IOException {
		HttpSource httpSource = newHttpSource();
		FileSink fileSink = newFileSink().binary(true);

		stream().create(
				generateStreamName(),
				"%s | aggregator --count=3 --aggregation=T(org.springframework.util.StringUtils).collectionToDelimitedString(#this.![payload],' ') | %s",
				httpSource, fileSink);

		httpSource.ensureReady().postData("Hello").postData("World").postData("!");

		assertThat(fileSink, eventually(hasContentsThat(equalTo("Hello World !"))));

	}
Shell integration tests for various simple processor modules.

@author Eric Bottard
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractProcessorsTests.java