From b35e1f94823841cc5f459ebf2c53502a02d83bd5 Mon Sep 17 00:00:00 2001 From: Jonathan Leibiusky Date: Wed, 5 Feb 2014 10:34:17 -0500 Subject: [PATCH] Update README on supported redis version --- README.md | 2 +- .../clients/jedis/tests/ConnectionTest.java | 57 +++++++++++++++++++ .../redis/clients/jedis/tests/JedisTest.java | 3 + 3 files changed, 61 insertions(+), 1 deletion(-) diff --git a/README.md b/README.md index 0a05970..ac3c67d 100644 --- a/README.md +++ b/README.md @@ -4,7 +4,7 @@ Jedis is a blazingly small and sane [Redis](http://github.com/antirez/redis "Red Jedis was conceived to be EASY to use. -Jedis is fully compatible with redis 2.6.14. +Jedis is fully compatible with redis 2.8.5. ## Community diff --git a/src/test/java/redis/clients/jedis/tests/ConnectionTest.java b/src/test/java/redis/clients/jedis/tests/ConnectionTest.java index 9cbaa12..5790562 100644 --- a/src/test/java/redis/clients/jedis/tests/ConnectionTest.java +++ b/src/test/java/redis/clients/jedis/tests/ConnectionTest.java @@ -1,11 +1,21 @@ package redis.clients.jedis.tests; +import java.util.List; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicBoolean; + import org.junit.After; import org.junit.Assert; import org.junit.Before; import org.junit.Test; import redis.clients.jedis.Connection; +import redis.clients.jedis.Jedis; +import redis.clients.jedis.JedisPool; +import redis.clients.jedis.SortingParams; import redis.clients.jedis.exceptions.JedisConnectionException; public class ConnectionTest extends Assert { @@ -41,4 +51,51 @@ public class ConnectionTest extends Assert { client.setTimeoutInfinite(); } + @Test + public void lala() throws InterruptedException { + final JedisPool jedisPool = new JedisPool("localhost"); + ExecutorService executor = Executors.newFixedThreadPool(10); + final AtomicBoolean ended = new AtomicBoolean(false); + + for (int n = 0; n < 10; n++) { + executor.execute(new Runnable() { + @Override + public void run() { + while (!ended.get()) { + Jedis jedis = jedisPool.getResource(); + SortingParams sortingParameters = new SortingParams(); + String sortBy = "1:2:*->status";// assume key is 1:2: + String filterSetName = "1:2:jobIds"; + sortingParameters.get("a", "b", "c");// assume that + // col1, + // col2, col3 are + // defined + sortingParameters.by(sortBy); + List filteredAndsortedList = null; + try { + filteredAndsortedList = jedis.sort(filterSetName, + sortingParameters); + System.out.println("Sorted List size " + + filteredAndsortedList.size()); + for (String str : filteredAndsortedList) { + // System.out.println(str); + } + } catch (Exception e) { + System.out.println("-----Exception thrown-----"); + System.out.println(e); + System.out.println(" returned value is " + + filteredAndsortedList); + e.printStackTrace(); + } finally { + jedisPool.returnResource(jedis); + } + } + } + }); + } + Thread.sleep(10000); + ended.set(true); + executor.shutdown(); + executor.awaitTermination(10, TimeUnit.SECONDS); + } } \ No newline at end of file diff --git a/src/test/java/redis/clients/jedis/tests/JedisTest.java b/src/test/java/redis/clients/jedis/tests/JedisTest.java index b123b05..8e4e524 100644 --- a/src/test/java/redis/clients/jedis/tests/JedisTest.java +++ b/src/test/java/redis/clients/jedis/tests/JedisTest.java @@ -4,13 +4,16 @@ import java.io.IOException; import java.net.URI; import java.net.URISyntaxException; import java.util.HashMap; +import java.util.List; import java.util.Map; import org.junit.Test; import redis.clients.jedis.Jedis; +import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisShardInfo; import redis.clients.jedis.Protocol; +import redis.clients.jedis.SortingParams; import redis.clients.jedis.exceptions.JedisConnectionException; import redis.clients.jedis.exceptions.JedisDataException; import redis.clients.jedis.tests.commands.JedisCommandTestBase;