@Test
	public void testFailedSink() {
		String filterContent = "BAD";
		stream(sources.http() + XD_DELIMITER + " filter --expression=payload=='good' " + XD_DELIMITER
				+ sinks.file());
		sources.httpSource().postData(filterContent);
		waitForXD();
		assertReceivedByProcessor(FILTER_MODULE_NAME, INPUT_CHANNEL_NAME, 1);
		assertReceivedByProcessor(FILTER_MODULE_NAME, OUTPUT_CHANNEL_NAME, 0);
		assertReceivedByProcessor(FILTER_MODULE_NAME, TO_SPEL_CHANNEL_NAME, 1);
		assertReceivedByProcessor(FILTER_MODULE_NAME, TO_SCRIPT_CHANNEL_NAME, 0);
		assertReceivedBySource(HTTP_MODULE_NAME, OUTPUT_CHANNEL_NAME, 1);

	}
Evaluates that a single data entry of "BAD" is filtered out and not stored. Verifies that the correct elements of
the filter, filtered out the data.
spring-xd-integration-test/src/test/java/org/springframework/xd/integration/test/ProcessorTest.java