Skip to content

Commit

Permalink
Deprecate Remove ShardedJedisPipeline class #2500 (#2508)
Browse files Browse the repository at this point in the history
* Deprecate Remove ShardedJedisPipeline class #2500

* putting back the tests
  • Loading branch information
sazzad16 authored Apr 14, 2021
1 parent 4e6d56b commit 4b1027b
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 0 deletions.
6 changes: 6 additions & 0 deletions src/main/java/redis/clients/jedis/BinaryShardedJedis.java
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down
5 changes: 5 additions & 0 deletions src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
Original file line number Diff line number Diff line change
Expand Up @@ -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<FutureResult> results = new ArrayList<>();
Expand Down

0 comments on commit 4b1027b

Please sign in to comment.