Skip to content

Commit 4b1027b

Browse files
authored
Deprecate Remove ShardedJedisPipeline class #2500 (#2508)
* Deprecate Remove ShardedJedisPipeline class #2500 * putting back the tests
1 parent 4e6d56b commit 4b1027b

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

src/main/java/redis/clients/jedis/BinaryShardedJedis.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -875,6 +875,12 @@ public Long linsert(final byte[] key, final ListPosition where, final byte[] piv
875875
return j.linsert(key, where, pivot, value);
876876
}
877877

878+
/**
879+
* @return
880+
* @deprecated The support of {@link ShardedJedisPipeline} and this method will be removed in next
881+
* major release.
882+
*/
883+
@Deprecated
878884
public ShardedJedisPipeline pipelined() {
879885
ShardedJedisPipeline pipeline = new ShardedJedisPipeline();
880886
pipeline.setShardedJedis(this);

src/main/java/redis/clients/jedis/ShardedJedisPipeline.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,11 @@
55
import java.util.List;
66
import java.util.Queue;
77

8+
/**
9+
* @deprecated The support of {@link ShardedJedisPipeline} will be removed in next major release,
10+
* due to several bugs and implementation issue.
11+
*/
12+
@Deprecated
813
public class ShardedJedisPipeline extends PipelineBase {
914
private BinaryShardedJedis jedis;
1015
private List<FutureResult> results = new ArrayList<>();

0 commit comments

Comments
 (0)