Skip to content

Commit 034716f

Browse files
committed
Add UNWATCH in pipeline interfaces
1 parent 5dbbd98 commit 034716f

File tree

5 files changed

+10
-10
lines changed

5 files changed

+10
-10
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -295,6 +295,12 @@ public Response<Long> sunionstore(byte[] dstkey, byte[]... keys) {
295295
return getResponse(BuilderFactory.LONG);
296296
}
297297

298+
@Override
299+
public Response<String> unwatch() {
300+
client.unwatch();
301+
return getResponse(BuilderFactory.STRING);
302+
}
303+
298304
@Override
299305
public Response<Long> zinterstore(String dstkey, String... sets) {
300306
client.zinterstore(dstkey, sets);

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -167,9 +167,4 @@ public Response<String> watch(byte[]... keys) {
167167
return getResponse(BuilderFactory.STRING);
168168
}
169169

170-
public Response<String> unwatch() {
171-
client.unwatch();
172-
return getResponse(BuilderFactory.STRING);
173-
}
174-
175170
}

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -91,9 +91,4 @@ public void setClient(Client client) {
9191
public void close() {
9292
clear();
9393
}
94-
95-
public Response<String> unwatch() {
96-
client.unwatch();
97-
return getResponse(BuilderFactory.STRING);
98-
}
9994
}

src/main/java/redis/clients/jedis/commands/MultiKeyBinaryRedisPipeline.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ public interface MultiKeyBinaryRedisPipeline {
5656

5757
Response<Long> sunionstore(byte[] dstkey, byte[]... keys);
5858

59+
Response<String> unwatch();
60+
5961
Response<Long> zinterstore(byte[] dstkey, byte[]... sets);
6062

6163
Response<Long> zinterstore(byte[] dstkey, ZParams params, byte[]... sets);

src/main/java/redis/clients/jedis/commands/MultiKeyCommandsPipeline.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,8 @@ public interface MultiKeyCommandsPipeline {
5555

5656
Response<Long> sunionstore(String dstkey, String... keys);
5757

58+
Response<String> unwatch();
59+
5860
Response<Long> zinterstore(String dstkey, String... sets);
5961

6062
Response<Long> zinterstore(String dstkey, ZParams params, String... sets);

0 commit comments

Comments
 (0)