diff --git a/src/main/java/redis/clients/jedis/BinaryJedis.java b/src/main/java/redis/clients/jedis/BinaryJedis.java index 6e53146..a6f2069 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryJedis.java @@ -1778,23 +1778,6 @@ public class BinaryJedis implements BasicCommands, BinaryJedisCommands, return transaction; } - @Deprecated - /** - * This method is deprecated due to its error prone - * and will be removed on next major release - * You can use multi() instead - * @see https://github.com/xetorthio/jedis/pull/498 - */ - public List multi(final TransactionBlock jedisTransaction) { - List results = null; - jedisTransaction.setClient(client); - client.multi(); - client.getOne(); // expected OK - jedisTransaction.execute(); - results = jedisTransaction.exec(); - return results; - } - protected void checkIsInMulti() { if (client.isInMulti()) { throw new JedisDataException( @@ -2230,19 +2213,6 @@ public class BinaryJedis implements BasicCommands, BinaryJedisCommands, return client.getStatusCodeReply(); } - @Deprecated - /** - * This method is deprecated due to its error prone with multi - * and will be removed on next major release - * You can use pipelined() instead - * @see https://github.com/xetorthio/jedis/pull/498 - */ - public List pipelined(final PipelineBlock jedisPipeline) { - jedisPipeline.setClient(client); - jedisPipeline.execute(); - return jedisPipeline.syncAndReturnAll(); - } - public Pipeline pipelined() { pipeline = new Pipeline(); pipeline.setClient(client); diff --git a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java index a8d17be..cb92e73 100644 --- a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java @@ -537,19 +537,6 @@ public class BinaryShardedJedis extends Sharded return j.linsert(key, where, pivot, value); } - @Deprecated - /** - * This method is deprecated due to its error prone with multi - * and will be removed on next major release - * You can use pipelined() instead - * @see https://github.com/xetorthio/jedis/pull/498 - */ - public List pipelined(ShardedJedisPipeline shardedJedisPipeline) { - shardedJedisPipeline.setShardedJedis(this); - shardedJedisPipeline.execute(); - return shardedJedisPipeline.getResults(); - } - public ShardedJedisPipeline pipelined() { ShardedJedisPipeline pipeline = new ShardedJedisPipeline(); pipeline.setShardedJedis(this); diff --git a/src/main/java/redis/clients/jedis/PipelineBlock.java b/src/main/java/redis/clients/jedis/PipelineBlock.java deleted file mode 100644 index 24bae84..0000000 --- a/src/main/java/redis/clients/jedis/PipelineBlock.java +++ /dev/null @@ -1,15 +0,0 @@ -package redis.clients.jedis; - -@Deprecated -/** - * This method is deprecated due to its error prone with multi - * and will be removed on next major release - * @see https://github.com/xetorthio/jedis/pull/498 - */ -public abstract class PipelineBlock extends Pipeline { - // For shadowing - @SuppressWarnings("unused") - private Client client; - - public abstract void execute(); -} diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java index 6b68e95..480d153 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java +++ b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java @@ -61,14 +61,6 @@ public class ShardedJedisPipeline extends PipelineBase { return formatted; } - /** - * This method will be removed in Jedis 3.0. Use the methods that return - * Response's and call sync(). - */ - @Deprecated - public void execute() { - } - @Override protected Client getClient(String key) { Client client = jedis.getShard(key).getClient(); diff --git a/src/main/java/redis/clients/jedis/TransactionBlock.java b/src/main/java/redis/clients/jedis/TransactionBlock.java deleted file mode 100644 index c038ac2..0000000 --- a/src/main/java/redis/clients/jedis/TransactionBlock.java +++ /dev/null @@ -1,28 +0,0 @@ -package redis.clients.jedis; - -import redis.clients.jedis.exceptions.JedisException; - -@Deprecated -/** - * This class is deprecated due to its error prone - * and will be removed on next major release - * @see https://github.com/xetorthio/jedis/pull/498 - */ -public abstract class TransactionBlock extends Transaction { - // For shadowing - @SuppressWarnings("unused") - private Client client; - - public TransactionBlock(Client client) { - super(client); - } - - public TransactionBlock() { - } - - public abstract void execute() throws JedisException; - - public void setClient(Client client) { - super.setClient(client); - } -} diff --git a/src/test/java/redis/clients/jedis/tests/ShardedJedisTest.java b/src/test/java/redis/clients/jedis/tests/ShardedJedisTest.java index 2413952..74b2e4b 100644 --- a/src/test/java/redis/clients/jedis/tests/ShardedJedisTest.java +++ b/src/test/java/redis/clients/jedis/tests/ShardedJedisTest.java @@ -142,37 +142,6 @@ public class ShardedJedisTest extends Assert { assertNotSame(s5, s6); } - @Test - public void shardedPipeline() { - List shards = new ArrayList(); - shards.add(new JedisShardInfo(redis1.getHost(), redis1.getPort())); - shards.add(new JedisShardInfo(redis2.getHost(), redis2.getPort())); - shards.get(0).setPassword("foobared"); - shards.get(1).setPassword("foobared"); - ShardedJedis jedis = new ShardedJedis(shards); - - final List keys = getKeysDifferentShard(jedis); - jedis.set(keys.get(0), "a"); - jedis.set(keys.get(1), "b"); - - assertNotSame(jedis.getShard(keys.get(0)), jedis.getShard(keys.get(1))); - - List results = jedis.pipelined(new ShardedJedisPipeline() { - public void execute() { - get(keys.get(0)); - get(keys.get(1)); - } - }); - - List expected = new ArrayList(2); - expected.add(SafeEncoder.encode("a")); - expected.add(SafeEncoder.encode("b")); - - assertEquals(2, results.size()); - assertArrayEquals(SafeEncoder.encode("a"), (byte[]) results.get(0)); - assertArrayEquals(SafeEncoder.encode("b"), (byte[]) results.get(1)); - } - @Test public void testMD5Sharding() { List shards = new ArrayList(3);