From 9258b582c93c1a75096f9cb97dc182183b00a878 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Wed, 16 Jun 2021 13:43:07 +0200 Subject: [PATCH] Ensure all pipelined commands use a dedicated connection to avoid lingering commands when using pipelining with flushing customization. Original Pull Request: #2088 --- .../data/redis/connection/lettuce/LettuceConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java index 06490aa79..7f6123beb 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java @@ -943,7 +943,7 @@ public class LettuceConnection extends AbstractRedisConnection { } RedisClusterAsyncCommands getAsyncConnection() { - if (isQueueing()) { + if (isQueueing() || isPipelined()) { return getAsyncDedicatedConnection(); } if (asyncSharedConn != null) {