diff --git a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java index edc7ac47a1..a06f75df76 100644 --- a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java @@ -875,6 +875,12 @@ public Long linsert(final byte[] key, final ListPosition where, final byte[] piv return j.linsert(key, where, pivot, value); } + /** + * @return + * @deprecated The support of {@link ShardedJedisPipeline} and this method will be removed in next + * major release. + */ + @Deprecated public ShardedJedisPipeline pipelined() { ShardedJedisPipeline pipeline = new ShardedJedisPipeline(); pipeline.setShardedJedis(this); diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java index 6f99fc3223..13a8ade95a 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java +++ b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java @@ -5,6 +5,11 @@ import java.util.List; import java.util.Queue; +/** + * @deprecated The support of {@link ShardedJedisPipeline} will be removed in next major release, + * due to several bugs and implementation issue. + */ +@Deprecated public class ShardedJedisPipeline extends PipelineBase { private BinaryShardedJedis jedis; private List results = new ArrayList<>();