@Test
	public void testRedisQueueExpressionSink() throws InterruptedException {
		final String listName = "testListExpression";
		final String stringToPost = "test";
		final HttpSource httpSource = newHttpSource();
		stream().create(generateStreamName(), "%s | redis --queueExpression='''%s'''", httpSource, listName);
		Thread.sleep(1000);
		httpSource.ensureReady().postData(stringToPost);
		byte[] leftPop = (byte[]) createTemplate().boundListOps(listName).leftPop(5, TimeUnit.SECONDS);
		Assert.assertEquals(stringToPost, new String(leftPop));
	}
Integration tests for Redis sink.

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