Synchronous test using Jedis API
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/387cc271 Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/387cc271 Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/387cc271 Branch: refs/heads/0.5.0 Commit: 387cc27178f4087b087ffbab0ec082982f2e7d53 Parents: dc04ab2 Author: Andrew Kennedy <[email protected]> Authored: Tue Apr 23 01:41:19 2013 +0100 Committer: Andrew Kennedy <[email protected]> Committed: Wed Apr 24 13:25:45 2013 +0100 ---------------------------------------------------------------------- .../entity/nosql/redis/JedisSupport.java | 42 ++++++++------------ 1 file changed, 16 insertions(+), 26 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/387cc271/software/nosql/src/test/java/brooklyn/entity/nosql/redis/JedisSupport.java ---------------------------------------------------------------------- diff --git a/software/nosql/src/test/java/brooklyn/entity/nosql/redis/JedisSupport.java b/software/nosql/src/test/java/brooklyn/entity/nosql/redis/JedisSupport.java index d481136..e086188 100644 --- a/software/nosql/src/test/java/brooklyn/entity/nosql/redis/JedisSupport.java +++ b/software/nosql/src/test/java/brooklyn/entity/nosql/redis/JedisSupport.java @@ -5,21 +5,15 @@ package brooklyn.entity.nosql.redis; import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertTrue; - -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.TimeUnit; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import redis.clients.jedis.Jedis; -import redis.clients.jedis.JedisPubSub; + +import com.google.common.base.Strings; /** * {@link RedisStore} testing using Jedis API. */ public class JedisSupport { - private static final Logger log = LoggerFactory.getLogger(JedisSupport.class); + private static final String TEST_DATA = Strings.repeat("0123456789", 16); private RedisStore redis; @@ -31,25 +25,21 @@ public class JedisSupport { * Exercise the {@link RedisStore} using the Jedis API. */ public void redisTest() throws Exception { - final CountDownLatch latch = new CountDownLatch(1); + writeData(TEST_DATA); + String result = readData(); + assertEquals(result, TEST_DATA); + } + public void writeData(String data) throws Exception { + Jedis client = getRedisClient(redis); + client.set("brooklyn", data); + client.disconnect(); + } + + public String readData() throws Exception { Jedis client = getRedisClient(redis); - client.subscribe(new JedisPubSub() { - public void onMessage(String channel, String message) { - assertEquals(channel, "brooklyn"); - assertEquals(message, "message"); - latch.countDown(); - } - public void onSubscribe(String channel, int subscribedChannels) { } - public void onUnsubscribe(String channel, int subscribedChannels) { } - public void onPSubscribe(String pattern, int subscribedChannels) { } - public void onPUnsubscribe(String pattern, int subscribedChannels) { } - public void onPMessage(String pattern, String channel, String message) { } - }, "brooklyn"); - - client.publish("brooklyn", "message"); - - assertTrue(latch.await(60, TimeUnit.SECONDS)); + String result = client.get("brooklyn"); client.disconnect(); + return result; } private Jedis getRedisClient(RedisStore redis) {
