Revert "Update README on supported redis version"

This reverts commit b35e1f9482.
This commit is contained in:
Jonathan Leibiusky
2014-02-05 10:47:11 -05:00
parent 179498d4a3
commit 28e7d2af10
3 changed files with 1 additions and 61 deletions

View File

@@ -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 was conceived to be EASY to use.
Jedis is fully compatible with redis 2.8.5. Jedis is fully compatible with redis 2.6.14.
## Community ## Community

View File

@@ -1,21 +1,11 @@
package redis.clients.jedis.tests; 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.After;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import redis.clients.jedis.Connection; 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; import redis.clients.jedis.exceptions.JedisConnectionException;
public class ConnectionTest extends Assert { public class ConnectionTest extends Assert {
@@ -51,51 +41,4 @@ public class ConnectionTest extends Assert {
client.setTimeoutInfinite(); 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<String> 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);
}
} }

View File

@@ -4,16 +4,13 @@ import java.io.IOException;
import java.net.URI; import java.net.URI;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.HashMap; import java.util.HashMap;
import java.util.List;
import java.util.Map; import java.util.Map;
import org.junit.Test; import org.junit.Test;
import redis.clients.jedis.Jedis; import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisShardInfo; import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.Protocol; import redis.clients.jedis.Protocol;
import redis.clients.jedis.SortingParams;
import redis.clients.jedis.exceptions.JedisConnectionException; import redis.clients.jedis.exceptions.JedisConnectionException;
import redis.clients.jedis.exceptions.JedisDataException; import redis.clients.jedis.exceptions.JedisDataException;
import redis.clients.jedis.tests.commands.JedisCommandTestBase; import redis.clients.jedis.tests.commands.JedisCommandTestBase;