Skip to content

Commit 1288b4b

Browse files
author
dengliming
authored
Fix xrevrange in PipelineBase (#2436)
1 parent 34270c7 commit 1288b4b

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2079,13 +2079,13 @@ public Response<List<byte[]>> xrange(byte[] key, byte[] start, byte[] end, int c
20792079
@Override
20802080
public Response<List<StreamEntry>> xrevrange(String key, StreamEntryID end, StreamEntryID start,
20812081
int count) {
2082-
getClient(key).xrevrange(key, start, end, count);
2082+
getClient(key).xrevrange(key, end, start, count);
20832083
return getResponse(BuilderFactory.STREAM_ENTRY_LIST);
20842084
}
20852085

20862086
@Override
20872087
public Response<List<byte[]>> xrevrange(byte[] key, byte[] end, byte[] start, int count) {
2088-
getClient(key).xrevrange(key, start, end, count);
2088+
getClient(key).xrevrange(key, end, start, count);
20892089
return getResponse(BuilderFactory.BYTE_ARRAY_LIST);
20902090
}
20912091

src/test/java/redis/clients/jedis/tests/commands/StreamsCommandsTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -561,6 +561,11 @@ public void pipeline() {
561561
assertEquals(map, entries.get(0).getFields());
562562
assertEquals(id2.get(), entries.get(1).getID());
563563
assertEquals(map, entries.get(1).getFields());
564+
565+
p = jedis.pipelined();
566+
Response<List<StreamEntry>> results2 = p.xrevrange("stream1", null, id1.get(), 2);
567+
p.sync();
568+
assertEquals(2, results2.get().size());
564569
}
565570

566571
@Test

0 commit comments

Comments
 (0)