@Test
	public void testRedisTopicExpressionSink() throws InterruptedException {
		String topicName = "testTopicExpression";
		CountDownLatch latch = new CountDownLatch(1);
		setupMessageListener(latch, topicName);
		final HttpSource httpSource = newHttpSource();
		stream().create(generateStreamName(), "%s | redis --topicExpression='''%s'''", httpSource,
				topicName);
		Thread.sleep(1000);
		final String stringToPost = "test";
		httpSource.ensureReady().postData(stringToPost);
		latch.await(3, TimeUnit.SECONDS);
		assertEquals(0, latch.getCount());
		container.stop();
	}
Integration tests for Redis sink.

@author Ilayaperumal Gopinathan
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractRedisSinkTests.java