Skip to content

Commit 479b4a2

Browse files
committed
Fix XREVRANGE using Lettuce to use the same connection.
XREVRANGE using Lettuce uses now the same connection instead of pinning execution to a dedicated connection. Closes #2078
1 parent e11668c commit 479b4a2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ public List<ByteRecord> xRevRange(byte[] key, Range<String> range, Limit limit)
366366
io.lettuce.core.Range<String> lettuceRange = RangeConverter.toRange(range, Function.identity());
367367
io.lettuce.core.Limit lettuceLimit = LettuceConverters.toLimit(limit);
368368

369-
return connection.invoke(getAsyncDedicatedConnection())
369+
return connection.invoke()
370370
.fromMany(RedisStreamAsyncCommands::xrevrange, key, lettuceRange, lettuceLimit)
371371
.toList(StreamConverters.byteRecordConverter());
372372
}

0 commit comments

Comments
 (0)