You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2016/02/01 18:47:04 UTC
[46/50] brooklyn-library git commit: Synchronous test using Jedis API
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 <an...@cloudsoftcorp.com>
Authored: Tue Apr 23 01:41:19 2013 +0100
Committer: Andrew Kennedy <an...@cloudsoftcorp.com>
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) {