From 866010e71d177113b35fbae0c4bc24063610c9cc Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Wed, 9 Jun 2021 15:53:44 +0200 Subject: [PATCH] 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 --- .../data/redis/connection/lettuce/LettuceStreamCommands.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java index 35e59b9ea..36f656419 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceStreamCommands.java @@ -366,7 +366,7 @@ class LettuceStreamCommands implements RedisStreamCommands { io.lettuce.core.Range lettuceRange = RangeConverter.toRange(range, Function.identity()); io.lettuce.core.Limit lettuceLimit = LettuceConverters.toLimit(limit); - return connection.invoke(getAsyncDedicatedConnection()) + return connection.invoke() .fromMany(RedisStreamAsyncCommands::xrevrange, key, lettuceRange, lettuceLimit) .toList(StreamConverters.byteRecordConverter()); }