From d9c446e8449d616304cef61ff2fb0d2c7897dda3 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 708344cc2..408538e15 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 @@ -935,7 +935,7 @@ public class LettuceConnection extends AbstractRedisConnection { RedisClusterAsyncCommands getAsyncConnection() { - if (isQueueing()) { + if (isQueueing() || isPipelined()) { return getAsyncDedicatedConnection(); }