@Test
	public void testRedisStoreSink() throws InterruptedException {
		final String setName = "testSet";
		final String stringToPost = "test";
		final HttpSource httpSource = newHttpSource();
		stream().create(generateStreamName(), "%s | redis --key=%s --collectionType='SET'", httpSource,
				setName);
		Thread.sleep(1000);
		httpSource.ensureReady().postData(stringToPost);
		byte[] popped = (byte[]) createTemplate().boundSetOps(setName).pop();
		Assert.assertEquals(stringToPost, new String(popped));
	}
Integration tests for Redis sink.

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